105     while (env_->GetThreadPoolQueueLen(Env::Priority::LOW) != 0) {  in WaitThreadPoolsEmpty()
108     while (env_->GetThreadPoolQueueLen(Env::Priority::HIGH) != 0) {  in WaitThreadPoolsEmpty()
123     env_->SetBackgroundThreads(1, static_cast<Env::Priority>(pri));  in TEST_F()
124     env_->Schedule(&SetBool, &called, static_cast<Env::Priority>(pri));  in TEST_F()
295                  Env::Priority::LOW);  in TEST_P()
299                  Env::Priority::LOW, &sleeping_task1);  in TEST_P()
302   ASSERT_EQ(0, env_->UnSchedule(&called, Env::Priority::LOW));  in TEST_P()
305   ASSERT_EQ(1, env_->UnSchedule(&sleeping_task1, Env::Priority::LOW));  in TEST_P()
472   env_->SetBackgroundThreads(kHighPoolSize, Env::Priority::HIGH);  in TEST_P()
474   ASSERT_EQ(0U, env_->GetThreadPoolQueueLen(Env::Priority::LOW));  in TEST_P()
475   ASSERT_EQ(0U, env_->GetThreadPoolQueueLen(Env::Priority::HIGH));  in TEST_P()
480     env_->Schedule(&CB::Run, &high_pool_job, Env::Priority::HIGH);  in TEST_P()
485              env_->GetThreadPoolQueueLen(Env::Priority::LOW) ||  in TEST_P()
487              env_->GetThreadPoolQueueLen(Env::Priority::HIGH)) {  in TEST_P()
497             env_->GetThreadPoolQueueLen(Env::Priority::LOW));  in TEST_P()
499             env_->GetThreadPoolQueueLen(Env::Priority::HIGH));  in TEST_P()
514   ASSERT_EQ(0U, env_->GetThreadPoolQueueLen(Env::Priority::LOW));  in TEST_P()
515   ASSERT_EQ(0U, env_->GetThreadPoolQueueLen(Env::Priority::HIGH));  in TEST_P()
522   env_->IncBackgroundThreadsIfNeeded(kLowPoolSize - 1, Env::Priority::LOW);  in TEST_P()
523   env_->IncBackgroundThreadsIfNeeded(kHighPoolSize + 1, Env::Priority::HIGH);  in TEST_P()
530     env_->Schedule(&CB::Run, &high_pool_job, Env::Priority::HIGH);  in TEST_P()
535              env_->GetThreadPoolQueueLen(Env::Priority::LOW) ||  in TEST_P()
537              env_->GetThreadPoolQueueLen(Env::Priority::HIGH)) {  in TEST_P()
546             env_->GetThreadPoolQueueLen(Env::Priority::LOW));  in TEST_P()
548             env_->GetThreadPoolQueueLen(Env::Priority::HIGH));  in TEST_P()
563   env_->SetBackgroundThreads(kHighPoolSize, Env::Priority::HIGH);  in TEST_P()
573   env_->SetBackgroundThreads(1, Env::Priority::HIGH);  in TEST_P()
578                    Env::Priority::HIGH);  in TEST_P()
581   ASSERT_EQ(2U, env_->GetThreadPoolQueueLen(Env::Priority::HIGH));  in TEST_P()
587   env_->SetBackgroundThreads(2, Env::Priority::HIGH);  in TEST_P()
589   ASSERT_EQ(1U, env_->GetThreadPoolQueueLen(Env::Priority::HIGH));  in TEST_P()
595   env_->SetBackgroundThreads(1, Env::Priority::HIGH);  in TEST_P()
597   ASSERT_EQ(1U, env_->GetThreadPoolQueueLen(Env::Priority::HIGH));  in TEST_P()
605   ASSERT_EQ(1U, env_->GetThreadPoolQueueLen(Env::Priority::HIGH));  in TEST_P()
611   env_->SetBackgroundThreads(5, Env::Priority::HIGH);  in TEST_P()
613   ASSERT_EQ(0U, env_->GetThreadPoolQueueLen(Env::Priority::HIGH));  in TEST_P()
620   env_->SetBackgroundThreads(7, Env::Priority::HIGH);  in TEST_P()
623   ASSERT_EQ(0U, env_->GetThreadPoolQueueLen(Env::Priority::HIGH));  in TEST_P()
624   env_->SetBackgroundThreads(3, Env::Priority::HIGH);  in TEST_P()
626   ASSERT_EQ(0U, env_->GetThreadPoolQueueLen(Env::Priority::HIGH));  in TEST_P()
627   env_->SetBackgroundThreads(4, Env::Priority::HIGH);  in TEST_P()
629   ASSERT_EQ(0U, env_->GetThreadPoolQueueLen(Env::Priority::HIGH));  in TEST_P()
630   env_->SetBackgroundThreads(5, Env::Priority::HIGH);  in TEST_P()
632   ASSERT_EQ(0U, env_->GetThreadPoolQueueLen(Env::Priority::HIGH));  in TEST_P()
633   env_->SetBackgroundThreads(4, Env::Priority::HIGH);  in TEST_P()
635   ASSERT_EQ(0U, env_->GetThreadPoolQueueLen(Env::Priority::HIGH));  in TEST_P()
643                    Env::Priority::HIGH);  in TEST_P()
648   ASSERT_EQ(2U, env_->GetThreadPoolQueueLen(Env::Priority::HIGH));  in TEST_P()
666   ASSERT_EQ(0U, env_->GetThreadPoolQueueLen(Env::Priority::HIGH));  in TEST_P()
672   env_->SetBackgroundThreads(1, Env::Priority::HIGH);  in TEST_P()
692                  Env::Priority::HIGH);  in TEST_P()
694                  Env::Priority::HIGH);  in TEST_P()
696   ASSERT_GT(env_->GetThreadPoolQueueLen(Env::Priority::HIGH), (unsigned int)0);  in TEST_P()
700   env_->SetBackgroundThreads(4, Env::Priority::HIGH);  in TEST_P()
702   ASSERT_EQ((unsigned int)0, env_->GetThreadPoolQueueLen(Env::Priority::HIGH));  in TEST_P()
707   env_->SetBackgroundThreads(1, Env::Priority::HIGH);  in TEST_P()