Lines Matching refs:thread_pool
64 ThreadPool thread_pool("Thread pool test thread pool", num_threads); in TEST_F() local
68 thread_pool.AddTask(self, new CountTask(&count)); in TEST_F()
70 thread_pool.StartWorkers(self); in TEST_F()
72 thread_pool.Wait(self, true, false); in TEST_F()
79 ThreadPool thread_pool("Thread pool test thread pool", num_threads); in TEST_F() local
83 thread_pool.AddTask(self, new CountTask(&count)); in TEST_F()
89 thread_pool.StartWorkers(self); in TEST_F()
91 thread_pool.StopWorkers(self); in TEST_F()
93 thread_pool.AddTask(self, new CountTask(&bad_count)); in TEST_F()
98 thread_pool.StartWorkers(self); in TEST_F()
99 thread_pool.Wait(self, false, false); in TEST_F()
104 ThreadPool thread_pool("Thread pool test thread pool", num_threads); in TEST_F() local
109 thread_pool.AddTask(self, new CountTask(&count)); in TEST_F()
113 thread_pool.StartWorkers(self); in TEST_F()
115 thread_pool.StopWorkers(self); in TEST_F()
117 thread_pool.Wait(self, false, false); // We should not deadlock here. in TEST_F()
121 thread_pool.StartWorkers(self); in TEST_F()
122 thread_pool.Wait(self, /* do_work= */ true, false); in TEST_F()
127 TreeTask(ThreadPool* const thread_pool, AtomicInteger* count, int depth) in TreeTask() argument
128 : thread_pool_(thread_pool), in TreeTask()
154 ThreadPool thread_pool("Thread pool test thread pool", num_threads); in TEST_F() local
157 thread_pool.AddTask(self, new TreeTask(&thread_pool, &count, depth)); in TEST_F()
158 thread_pool.StartWorkers(self); in TEST_F()
159 thread_pool.Wait(self, true, false); in TEST_F()
195 ThreadPool thread_pool("Thread pool test thread pool", 1); in TEST_F() local
196 thread_pool.AddTask(self, new NoPeerTask()); in TEST_F()
197 thread_pool.StartWorkers(self); in TEST_F()
198 thread_pool.Wait(self, false, false); in TEST_F()
207 ThreadPool thread_pool("Thread pool test thread pool", 1, true); in TEST_F() local
208 thread_pool.AddTask(self, new PeerTask()); in TEST_F()
209 thread_pool.StartWorkers(self); in TEST_F()
210 thread_pool.Wait(self, false, false); in TEST_F()