| /external/chromium_org/sandbox/win/src/ |
| threadpool_unittest.cc | 20 Win2kThreadPool thread_pool; local
22 EXPECT_EQ(0, thread_pool.OutstandingWaits());
28 EXPECT_FALSE(thread_pool.RegisterWait(0, event1, EmptyCallBack, &context));
29 EXPECT_EQ(0, thread_pool.OutstandingWaits());
31 EXPECT_TRUE(thread_pool.RegisterWait(this, event1, EmptyCallBack, &context));
32 EXPECT_EQ(1, thread_pool.OutstandingWaits());
33 EXPECT_TRUE(thread_pool.RegisterWait(this, event2, EmptyCallBack, &context));
34 EXPECT_EQ(2, thread_pool.OutstandingWaits());
36 EXPECT_TRUE(thread_pool.UnRegisterWaits(this));
37 EXPECT_EQ(0, thread_pool.OutstandingWaits())
45 Win2kThreadPool thread_pool; local
74 Win2kThreadPool thread_pool; local
[all...] |
| target_process.h | 37 ThreadProvider* thread_pool);
58 // IPC server. The IPC server uses the services of the thread_pool.
|
| target_process.cc | 68 HANDLE job, ThreadProvider* thread_pool)
69 // This object owns everything initialized here except thread_pool and
75 thread_pool_(thread_pool),
|
| /art/runtime/ |
| thread_pool_test.cc | 22 #include "thread_pool.h"
62 ThreadPool thread_pool(num_threads);
66 thread_pool.AddTask(self, new CountTask(&count));
68 thread_pool.StartWorkers(self);
70 thread_pool.Wait(self, true, false);
77 ThreadPool thread_pool(num_threads);
81 thread_pool.AddTask(self, new CountTask(&count));
87 thread_pool.StartWorkers(self);
89 thread_pool.StopWorkers(self);
91 thread_pool.AddTask(self, new CountTask(&bad_count))
[all...] |
| barrier_test.cc | 24 #include "thread_pool.h"
69 ThreadPool thread_pool(num_threads);
75 thread_pool.AddTask(self, new CheckWaitTask(&barrier, &count1, &count2, &count3));
77 thread_pool.StartWorkers(self);
90 thread_pool.Wait(self, true, false);
124 ThreadPool thread_pool(num_threads);
130 thread_pool.AddTask(self, new CheckPassTask(&barrier, &count, num_sub_tasks));
132 thread_pool.StartWorkers(self);
|
| thread_pool.cc | 17 #include "thread_pool.h"
28 ThreadPoolWorker::ThreadPoolWorker(ThreadPool* thread_pool, const std::string& name,
30 : thread_pool_(thread_pool),
198 WorkStealingWorker::WorkStealingWorker(ThreadPool* thread_pool, const std::string& name,
200 : ThreadPoolWorker(thread_pool, name, stack_size), task_(NULL) {}
205 WorkStealingThreadPool* thread_pool = down_cast<WorkStealingThreadPool*>(thread_pool_); local
211 MutexLock mu(self, thread_pool->work_steal_lock_);
227 while (thread_pool->GetTaskCount(self) == 0) {
231 MutexLock mu(self, thread_pool->work_steal_lock_);
233 steal_from_task = thread_pool->FindTaskToStealFrom(self)
[all...] |
| thread_pool.h | 49 ThreadPoolWorker(ThreadPool* thread_pool, const std::string& name, size_t stack_size);
160 WorkStealingWorker(ThreadPool* thread_pool, const std::string& name, size_t stack_size);
|
| Android.mk | 124 thread_pool.cc \
|
| /art/compiler/driver/ |
| compiler_driver.h | 36 #include "thread_pool.h"
331 ThreadPool& thread_pool, base::TimingLogger& timings)
340 ThreadPool& thread_pool, base::TimingLogger& timings)
343 ThreadPool& thread_pool, base::TimingLogger& timings)
347 ThreadPool& thread_pool, base::TimingLogger& timings);
349 ThreadPool& thread_pool, base::TimingLogger& timings)
353 ThreadPool& thread_pool, base::TimingLogger& timings)
356 ThreadPool& thread_pool, base::TimingLogger& timings)
364 ThreadPool& thread_pool, base::TimingLogger& timings);
366 ThreadPool& thread_pool, base::TimingLogger& timings
[all...] |
| compiler_driver.cc | 47 #include "thread_pool.h"
492 UniquePtr<ThreadPool> thread_pool(new ThreadPool(thread_count_ - 1));
493 PreCompile(class_loader, dex_files, *thread_pool.get(), timings);
494 Compile(class_loader, dex_files, *thread_pool.get(), timings);
556 UniquePtr<ThreadPool> thread_pool(new ThreadPool(0U));
557 PreCompile(jclass_loader, dex_files, *thread_pool.get(), timings);
578 ThreadPool& thread_pool, base::TimingLogger& timings) {
582 ResolveDexFile(class_loader, *dex_file, thread_pool, timings);
587 ThreadPool& thread_pool, base::TimingLogger& timings) {
590 Resolve(class_loader, dex_files, thread_pool, timings)
[all...] |
| /art/runtime/gc/collector/ |
| mark_sweep.cc | 632 MarkStackTask(ThreadPool* thread_pool, MarkSweep* mark_sweep, size_t mark_stack_size,
635 thread_pool_(thread_pool),
744 CardScanTask(ThreadPool* thread_pool, MarkSweep* mark_sweep, accounting::SpaceBitmap* bitmap,
747 : MarkStackTask<false>(thread_pool, mark_sweep, mark_stack_size, mark_stack_obj),
789 ThreadPool* thread_pool = GetHeap()->GetThreadPool(); local
828 auto* task = new CardScanTask(thread_pool, this, space->GetMarkBitmap(), card_begin,
831 thread_pool->AddTask(self, task);
845 thread_pool->SetMaxActiveWorkers(thread_count - 1);
846 thread_pool->StartWorkers(self);
847 thread_pool->Wait(self, true, true)
945 ThreadPool* thread_pool = heap_->GetThreadPool(); local
1404 ThreadPool* thread_pool = GetHeap()->GetThreadPool(); local
[all...] |
| /external/chromium_org/media/tools/constrained_network_server/ |
| cns.py | 375 default=cherrypy._cpserver.Server.thread_pool,
439 cherrypy.config.update({'server.thread_pool': options.threads})
|
