Lines Matching refs:peer_
94 peer_(pool_.get()),
101 peer_.set_num_idle_threads_cv(new ConditionVariable(peer_.lock()));
117 base::AutoLock pool_locked(*peer_.lock());
118 while (peer_.num_idle_threads() < num_idle_threads) {
119 peer_.num_idle_threads_cv()->Wait();
138 base::PosixDynamicThreadPool::PosixDynamicThreadPoolPeer peer_;
152 EXPECT_EQ(0, peer_.num_idle_threads());
154 EXPECT_EQ(0U, peer_.pending_tasks().size());
181 EXPECT_EQ(2, peer_.num_idle_threads());
197 EXPECT_EQ(2, peer_.num_idle_threads()) << "Existing threads are now idle.";
217 EXPECT_EQ(2, peer_.num_idle_threads());
222 base::AutoLock locked(*peer_.lock());
223 while (peer_.num_idle_threads() > 0) {
224 peer_.pending_tasks_available_cv()->Signal();
225 peer_.num_idle_threads_cv()->Wait();
249 EXPECT_EQ(1, peer_.num_idle_threads());
