OLD | NEW |
1 // Copyright (c) 2012, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2012, the Dart project authors. Please see the AUTHORS file |
2 // for details. All rights reserved. Use of this source code is governed by a | 2 // for details. All rights reserved. Use of this source code is governed by a |
3 // BSD-style license that can be found in the LICENSE file. | 3 // BSD-style license that can be found in the LICENSE file. |
4 | 4 |
5 #ifndef VM_THREAD_POOL_H_ | 5 #ifndef VM_THREAD_POOL_H_ |
6 #define VM_THREAD_POOL_H_ | 6 #define VM_THREAD_POOL_H_ |
7 | 7 |
| 8 #include "vm/allocation.h" |
8 #include "vm/globals.h" | 9 #include "vm/globals.h" |
9 #include "vm/os_thread.h" | 10 #include "vm/os_thread.h" |
10 | 11 |
11 namespace dart { | 12 namespace dart { |
12 | 13 |
| 14 class ReaperTask; |
| 15 |
13 class ThreadPool { | 16 class ThreadPool { |
14 public: | 17 public: |
15 // Subclasses of Task are able to run on a ThreadPool. | 18 // Subclasses of Task are able to run on a ThreadPool. |
16 class Task { | 19 class Task { |
17 protected: | 20 protected: |
18 Task(); | 21 Task(); |
19 | 22 |
20 public: | 23 public: |
21 virtual ~Task(); | 24 virtual ~Task(); |
22 | 25 |
23 // Override this to provide task-specific behavior. | 26 // Override this to provide task-specific behavior. |
24 virtual void Run() = 0; | 27 virtual void Run() = 0; |
25 | 28 |
26 private: | 29 private: |
27 DISALLOW_COPY_AND_ASSIGN(Task); | 30 DISALLOW_COPY_AND_ASSIGN(Task); |
28 }; | 31 }; |
29 | 32 |
30 ThreadPool(); | 33 ThreadPool(); |
31 | 34 |
32 // Shuts down this thread pool. Causes workers to terminate | 35 // Shuts down this thread pool. Causes workers to terminate |
33 // themselves when they are active again. | 36 // themselves when they are active again. |
34 ~ThreadPool(); | 37 ~ThreadPool(); |
35 | 38 |
36 // Runs a task on the thread pool. | 39 // Runs a task on the thread pool. |
37 void Run(Task* task); | 40 void Run(Task* task); |
38 | 41 |
39 // Some simple stats. | 42 // Some simple stats. |
40 uint64_t workers_running() const { return count_running_; } | 43 uint64_t workers_running() const { return count_running_; } |
41 uint64_t workers_idle() const { return count_idle_; } | 44 uint64_t workers_idle() const { return count_idle_; } |
42 uint64_t workers_started() const { return count_started_; } | 45 uint64_t workers_started() const { return count_started_; } |
43 uint64_t workers_stopped() const { return count_stopped_; } | 46 uint64_t workers_stopped() const { return count_stopped_; } |
44 | 47 |
45 private: | 48 private: |
46 friend class ThreadPoolTestPeer; | 49 friend class ReaperTask; |
47 | 50 |
48 class Worker { | 51 class Worker { |
49 public: | 52 public: |
50 explicit Worker(ThreadPool* pool); | 53 explicit Worker(ThreadPool* pool); |
51 | 54 |
52 // Sets a task on the worker. | 55 // Sets a task on the worker. |
53 void SetTask(Task* task); | 56 void SetTask(Task* task); |
54 | 57 |
55 // Starts the thread for the worker. This should only be called | 58 // Starts the thread for the worker. This should only be called |
56 // after a task has been set by the initial call to SetTask(). | 59 // after a task has been set by the initial call to SetTask(). |
57 void StartThread(); | 60 void StartThread(); |
58 | 61 |
59 // Main loop for a worker. | 62 // Main loop for a worker. Returns true if worker is removed from thread |
60 void Loop(); | 63 // lists, false otherwise. |
| 64 bool Loop(); |
61 | 65 |
62 // Causes worker to terminate eventually. | 66 // Causes worker to terminate eventually. |
63 void Shutdown(); | 67 void Shutdown(); |
64 | 68 |
| 69 // Get the Worker's thread id. |
| 70 ThreadId id() { return id_; } |
| 71 |
65 private: | 72 private: |
66 friend class ThreadPool; | 73 friend class ThreadPool; |
67 | 74 |
68 // The main entry point for new worker threads. | 75 // The main entry point for new worker threads. |
69 static void Main(uword args); | 76 static void Main(uword args); |
70 | 77 |
71 bool IsDone() const { return pool_ == NULL; } | 78 bool IsDone() const { return done_; } |
72 | 79 |
73 // Fields owned by Worker. | 80 // Fields owned by Worker. |
74 Monitor monitor_; | 81 Monitor monitor_; |
75 ThreadPool* pool_; | 82 ThreadPool* pool_; |
76 Task* task_; | 83 Task* task_; |
| 84 ThreadJoinId id_; |
| 85 bool started_; |
| 86 bool done_; |
77 | 87 |
78 // Fields owned by ThreadPool. Workers should not look at these | 88 // Fields owned by ThreadPool. Workers should not look at these |
79 // directly. It's like looking at the sun. | 89 // directly. It's like looking at the sun. |
80 bool owned_; // Protected by ThreadPool::mutex_ | 90 bool owned_; // Protected by ThreadPool::mutex_ |
81 Worker* all_next_; // Protected by ThreadPool::mutex_ | 91 Worker* all_next_; // Protected by ThreadPool::mutex_ |
82 Worker* idle_next_; // Protected by ThreadPool::mutex_ | 92 Worker* idle_next_; // Protected by ThreadPool::mutex_ |
83 | 93 |
| 94 Worker* shutdown_next_; // Protected by ThreadPool::exit_monitor |
| 95 |
84 DISALLOW_COPY_AND_ASSIGN(Worker); | 96 DISALLOW_COPY_AND_ASSIGN(Worker); |
85 }; | 97 }; |
86 | 98 |
| 99 class JoinList { |
| 100 public: |
| 101 explicit JoinList(ThreadJoinId id, JoinList* next) : id_(id), next_(next) { |
| 102 } |
| 103 |
| 104 static void Add(ThreadJoinId id, JoinList** list); |
| 105 |
| 106 static void Join(JoinList** list); |
| 107 |
| 108 ThreadJoinId id() const { return id_; } |
| 109 JoinList* next() const { return next_; } |
| 110 |
| 111 private: |
| 112 ThreadJoinId id_; |
| 113 JoinList* next_; |
| 114 |
| 115 DISALLOW_COPY_AND_ASSIGN(JoinList); |
| 116 }; |
| 117 |
87 void Shutdown(); | 118 void Shutdown(); |
88 | 119 |
89 // Expensive. Use only in assertions. | 120 // Expensive. Use only in assertions. |
90 bool IsIdle(Worker* worker); | 121 bool IsIdle(Worker* worker); |
91 | 122 |
92 bool RemoveWorkerFromIdleList(Worker* worker); | 123 bool RemoveWorkerFromIdleList(Worker* worker); |
93 bool RemoveWorkerFromAllList(Worker* worker); | 124 bool RemoveWorkerFromAllList(Worker* worker); |
94 | 125 |
| 126 void AddWorkerToShutdownList(Worker* worker); |
| 127 bool RemoveWorkerFromShutdownList(Worker* worker); |
| 128 |
| 129 void ReapExitedIdleThreads(); |
| 130 |
95 // Worker operations. | 131 // Worker operations. |
96 void SetIdle(Worker* worker); | 132 void SetIdle(Worker* worker); |
97 bool ReleaseIdleWorker(Worker* worker); | 133 bool ReleaseIdleWorker(Worker* worker); |
98 | 134 |
99 Mutex mutex_; | 135 Mutex mutex_; |
100 bool shutting_down_; | 136 bool shutting_down_; |
101 Worker* all_workers_; | 137 Worker* all_workers_; |
102 Worker* idle_workers_; | 138 Worker* idle_workers_; |
103 uint64_t count_started_; | 139 uint64_t count_started_; |
104 uint64_t count_stopped_; | 140 uint64_t count_stopped_; |
105 uint64_t count_running_; | 141 uint64_t count_running_; |
106 uint64_t count_idle_; | 142 uint64_t count_idle_; |
| 143 JoinList* idle_join_list_; |
107 | 144 |
108 static Monitor* exit_monitor_; // Used only in testing. | 145 Monitor exit_monitor_; |
109 static int* exit_count_; // Used only in testing. | 146 Worker* shutting_down_workers_; |
| 147 JoinList* join_list_; |
110 | 148 |
111 DISALLOW_COPY_AND_ASSIGN(ThreadPool); | 149 DISALLOW_COPY_AND_ASSIGN(ThreadPool); |
112 }; | 150 }; |
113 | 151 |
114 } // namespace dart | 152 } // namespace dart |
115 | 153 |
116 #endif // VM_THREAD_POOL_H_ | 154 #endif // VM_THREAD_POOL_H_ |
OLD | NEW |