From 36d22d82aa202bb199967e9512281e9a53db42c9 Mon Sep 17 00:00:00 2001 From: Daniel Baumann Date: Sun, 7 Apr 2024 21:33:14 +0200 Subject: Adding upstream version 115.7.0esr. Signed-off-by: Daniel Baumann --- js/src/vm/InternalThreadPool.h | 74 ++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 74 insertions(+) create mode 100644 js/src/vm/InternalThreadPool.h (limited to 'js/src/vm/InternalThreadPool.h') 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, 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 threads_; + + js::ConditionVariable wakeup; + + HelperThreadLockData queuedTasks; + + HelperThreadLockData terminating; +}; + +} // namespace js + +#endif /* vm_InternalThreadPool_h */ -- cgit v1.2.3