| /art/runtime/ |
| thread_pool_test.cc | 17 #include "thread_pool.h"
63 ThreadPool thread_pool("Thread pool test thread pool", num_threads);
67 thread_pool.AddTask(self, new CountTask(&count));
69 thread_pool.StartWorkers(self);
71 thread_pool.Wait(self, true, false);
78 ThreadPool thread_pool("Thread pool test thread pool", num_threads);
82 thread_pool.AddTask(self, new CountTask(&count));
88 thread_pool.StartWorkers(self);
90 thread_pool.StopWorkers(self);
92 thread_pool.AddTask(self, new CountTask(&bad_count))
[all...] |
| barrier_test.cc | 24 #include "thread_pool.h"
63 ThreadPool thread_pool("Barrier test thread pool", num_threads);
69 thread_pool.AddTask(self, new CheckWaitTask(&barrier, &count1, &count2));
71 thread_pool.StartWorkers(self);
80 thread_pool.Wait(self, true, false);
114 ThreadPool thread_pool("Barrier test thread pool", num_threads);
120 thread_pool.AddTask(self, new CheckPassTask(&barrier, &count, num_sub_tasks));
122 thread_pool.StartWorkers(self);
|
| monitor_test.cc | 30 #include "thread_pool.h"
320 ThreadPool thread_pool(pool_name, 3);
321 thread_pool.AddTask(self, new CreateTask(test, create_sleep, c_millis, c_expected));
323 thread_pool.AddTask(self, new InterruptTask(test, use_sleep, static_cast<uint64_t>(u_millis)));
325 thread_pool.AddTask(self, new UseTask(test, use_sleep, u_millis, u_expected));
327 thread_pool.AddTask(self, new WatchdogTask(test));
328 thread_pool.StartWorkers(self);
342 thread_pool.StopWorkers(self);
|
| thread_pool.h | 66 ThreadPoolWorker(ThreadPool* thread_pool, const std::string& name, size_t stack_size);
|
| thread_pool.cc | 17 #include "thread_pool.h"
36 ThreadPoolWorker::ThreadPoolWorker(ThreadPool* thread_pool, const std::string& name,
38 : thread_pool_(thread_pool),
|
| oat_file_assistant_test.cc | [all...] |
| Android.mk | 184 thread_pool.cc \
|
| /art/runtime/gc/ |
| task_processor_test.cc | 20 #include "thread_pool.h"
66 ThreadPool thread_pool("task processor test", 1U);
75 thread_pool.AddTask(self, new WorkUntilDoneTask(&task_processor, &done_running));
76 thread_pool.StartWorkers(self);
84 thread_pool.Wait(self, true, false);
96 thread_pool.AddTask(self, new WorkUntilDoneTask(&task_processor, &done_running));
97 thread_pool.StartWorkers(self);
98 thread_pool.Wait(self, true, false);
136 ThreadPool thread_pool("task processor test", 1U);
139 thread_pool.AddTask(self, new WorkUntilDoneTask(&task_processor, &done_running))
[all...] |
| /external/chromium-trace/catapult/third_party/Paste/paste/debug/ |
| watchthreads.py | 2 Watches the key ``paste.httpserver.thread_pool`` to see how many
189 if 'paste.httpserver.thread_pool' not in environ:
204 thread_pool = environ['paste.httpserver.thread_pool']
205 nworkers = thread_pool.nworkers
209 workers = thread_pool.worker_tracker.items()
228 actual_workers=len(thread_pool.workers),
235 track_threads=thread_pool.track_threads())
247 thread_pool = environ['paste.httpserver.thread_pool']
[all...] |
| /system/update_engine/payload_generator/ |
| full_update_generator.cc | 186 base::DelegateSimpleThreadPool thread_pool("full-update-generator",
188 thread_pool.Start();
190 thread_pool.AddWork(&processor);
191 thread_pool.JoinAll();
|
| /art/runtime/gc/space/ |
| large_object_space_test.cc | 154 ThreadPool thread_pool("Large object space test thread pool", kNumThreads);
156 thread_pool.AddTask(self, new AllocRaceTask(i, kNumIterations, 16 * KB, los));
159 thread_pool.StartWorkers(self);
161 thread_pool.Wait(self, true, false);
|
| /art/runtime/gc/collector/ |
| mark_sweep.cc | 651 MarkStackTask(ThreadPool* thread_pool,
656 thread_pool_(thread_pool),
809 CardScanTask(ThreadPool* thread_pool,
818 : MarkStackTask<false>(thread_pool, mark_sweep, mark_stack_size, mark_stack_obj),
860 ThreadPool* thread_pool = GetHeap()->GetThreadPool(); local
1012 ThreadPool* thread_pool = heap_->GetThreadPool(); local
1373 ThreadPool* thread_pool = GetHeap()->GetThreadPool(); local
[all...] |
| /external/autotest/server/hosts/ |
| testbed.py | 291 thread_pool = pool.ThreadPool(_POOL_SIZE)
292 thread_pool.map(self._install_device, arguments)
293 thread_pool.close()
|
| /external/autotest/site_utils/suite_scheduler/ |
| driver.py | 169 thread_pool = pool.ThreadPool(POOL_SIZE)
170 with contextlib.closing(thread_pool):
181 thread_pool.map(self.HandleBoard, args)
|
| /art/compiler/driver/ |
| compiler_driver.h | 41 #include "thread_pool.h"
569 ThreadPool* thread_pool,
580 ThreadPool* thread_pool,
591 ThreadPool* thread_pool,
616 ThreadPool* thread_pool,
|
| compiler_driver.cc | 67 #include "thread_pool.h"
[all...] |
| /external/chromium-trace/catapult/third_party/Paste/paste/ |
| httpserver.py | 262 if hasattr(self.server, 'thread_pool'):
265 self.server.thread_pool.worker_tracker[_thread.get_ident()][1] = self.wsgi_environ
266 self.wsgi_environ['paste.httpserver.thread_pool'] = self.server.thread_pool
[all...] |
