32   void Run(Thread* self) override {  in Run()  argument
34       LOG(INFO) << "Running: " << *self;  in Run()
63   Thread* self = Thread::Current();  in TEST_F()  local
69     thread_pool->AddTask(self, new CountTask(&count));  in TEST_F()
71   thread_pool->StartWorkers(self);  in TEST_F()
73   thread_pool->Wait(self, true, false);  in TEST_F()
79   Thread* self = Thread::Current();  in TEST_F()  local
85     thread_pool->AddTask(self, new CountTask(&count));  in TEST_F()
91   thread_pool->StartWorkers(self);  in TEST_F()
93   thread_pool->StopWorkers(self);  in TEST_F()
95   thread_pool->AddTask(self, new CountTask(&bad_count));  in TEST_F()
100   thread_pool->StartWorkers(self);  in TEST_F()
101   thread_pool->Wait(self, false, false);  in TEST_F()
105   Thread* self = Thread::Current();  in TEST_F()  local
112     thread_pool->AddTask(self, new CountTask(&count));  in TEST_F()
116   thread_pool->StartWorkers(self);  in TEST_F()
118   thread_pool->StopWorkers(self);  in TEST_F()
120   thread_pool->Wait(self, false, false);  // We should not deadlock here.  in TEST_F()
124   thread_pool->StartWorkers(self);  in TEST_F()
125   thread_pool->Wait(self, /* do_work= */ true, false);  in TEST_F()
135   void Run(Thread* self) override {  in Run()  argument
137       thread_pool_->AddTask(self, new TreeTask(thread_pool_, count_, depth_ - 1));  in Run()
138       thread_pool_->AddTask(self, new TreeTask(thread_pool_, count_, depth_ - 1));  in Run()
156   Thread* self = Thread::Current();  in TEST_F()  local
161   thread_pool->AddTask(self, new TreeTask(thread_pool.get(), &count, depth));  in TEST_F()
162   thread_pool->StartWorkers(self);  in TEST_F()
163   thread_pool->Wait(self, true, false);  in TEST_F()
171   void Run(Thread* self) override {  in Run()  argument
172     ScopedObjectAccess soa(self);  in Run()
173     CHECK(self->GetPeer() != nullptr);  in Run()
185   void Run(Thread* self) override {  in Run()  argument
186     ScopedObjectAccess soa(self);  in Run()
187     CHECK(self->GetPeer() == nullptr);  in Run()
197   Thread* self = Thread::Current();  in TEST_F()  local
201     thread_pool->AddTask(self, new NoPeerTask());  in TEST_F()
202     thread_pool->StartWorkers(self);  in TEST_F()
203     thread_pool->Wait(self, false, false);  in TEST_F()
208     self->TransitionFromSuspendedToRunnable();  in TEST_F()
214     thread_pool->AddTask(self, new PeerTask());  in TEST_F()
215     thread_pool->StartWorkers(self);  in TEST_F()
216     thread_pool->Wait(self, false, false);  in TEST_F()