diff options
author | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-04-07 19:33:14 +0000 |
---|---|---|
committer | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-04-07 19:33:14 +0000 |
commit | 36d22d82aa202bb199967e9512281e9a53db42c9 (patch) | |
tree | 105e8c98ddea1c1e4784a60a5a6410fa416be2de /js/src/vm/InternalThreadPool.h | |
parent | Initial commit. (diff) | |
download | firefox-esr-36d22d82aa202bb199967e9512281e9a53db42c9.tar.xz firefox-esr-36d22d82aa202bb199967e9512281e9a53db42c9.zip |
Adding upstream version 115.7.0esr.upstream/115.7.0esr
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'js/src/vm/InternalThreadPool.h')
-rw-r--r-- | js/src/vm/InternalThreadPool.h | 74 |
1 files changed, 74 insertions, 0 deletions
diff --git a/js/src/vm/InternalThreadPool.h b/js/src/vm/InternalThreadPool.h new file mode 100644 index 0000000000..1d5c6d1a43 --- /dev/null +++ b/js/src/vm/InternalThreadPool.h @@ -0,0 +1,74 @@ +/* -*- Mode: C++; tab-width: 8; indent-tabs-mode: nil; c-basic-offset: 2 -*- + * vim: set ts=8 sts=2 et sw=2 tw=80: + * This Source Code Form is subject to the terms of the Mozilla Public + * License, v. 2.0. If a copy of the MPL was not distributed with this + * file, You can obtain one at http://mozilla.org/MPL/2.0/. */ + +/* + * An internal thread pool, used for the shell and when + * JS::SetHelperThreadTaskCallback not called. + */ + +#ifndef vm_InternalThreadPool_h +#define vm_InternalThreadPool_h + +#include "js/AllocPolicy.h" +#include "js/UniquePtr.h" +#include "js/Vector.h" +#include "threading/ConditionVariable.h" +#include "threading/ProtectedData.h" + +namespace JS { +enum class DispatchReason; +}; + +namespace js { + +class AutoLockHelperThreadState; +class HelperThread; + +using HelperThreadVector = + Vector<UniquePtr<HelperThread>, 0, SystemAllocPolicy>; + +class InternalThreadPool { + public: + static bool Initialize(size_t threadCount, AutoLockHelperThreadState& lock); + static void ShutDown(AutoLockHelperThreadState& lock); + + static bool IsInitialized() { return Instance; } + static InternalThreadPool& Get(); + + bool ensureThreadCount(size_t threadCount, AutoLockHelperThreadState& lock); + size_t threadCount(const AutoLockHelperThreadState& lock); + + size_t sizeOfIncludingThis(mozilla::MallocSizeOf mallocSizeOf, + const AutoLockHelperThreadState& lock) const; + + private: + static void DispatchTask(JS::DispatchReason reason); + + void dispatchTask(JS::DispatchReason reason); + void shutDown(AutoLockHelperThreadState& lock); + + HelperThreadVector& threads(const AutoLockHelperThreadState& lock); + const HelperThreadVector& threads( + const AutoLockHelperThreadState& lock) const; + + void notifyAll(const AutoLockHelperThreadState& lock); + void wait(AutoLockHelperThreadState& lock); + friend class HelperThread; + + static InternalThreadPool* Instance; + + HelperThreadLockData<HelperThreadVector> threads_; + + js::ConditionVariable wakeup; + + HelperThreadLockData<size_t> queuedTasks; + + HelperThreadLockData<bool> terminating; +}; + +} // namespace js + +#endif /* vm_InternalThreadPool_h */ |