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
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()
78   Thread* self = Thread::Current();  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()
103   Thread* self = Thread::Current();  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()
132   void Run(Thread* self) override {  in Run()  argument
134       thread_pool_->AddTask(self, new TreeTask(thread_pool_, count_, depth_ - 1));  in Run()
135       thread_pool_->AddTask(self, new TreeTask(thread_pool_, count_, depth_ - 1));  in Run()
153   Thread* self = Thread::Current();  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()
167   void Run(Thread* self) override {  in Run()  argument
168     ScopedObjectAccess soa(self);  in Run()
169     CHECK(self->GetPeer() != nullptr);  in Run()
181   void Run(Thread* self) override {  in Run()  argument
182     ScopedObjectAccess soa(self);  in Run()
183     CHECK(self->GetPeer() == nullptr);  in Run()
193   Thread* self = Thread::Current();  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()
203     self->TransitionFromSuspendedToRunnable();  in TEST_F()
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()