blob: 1d5c6d1a43162986efffd6ae989df13607b1f09b (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
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 */
|
