| 266 | } |
| 267 | |
| 268 | void ThreadPoolToken::Wait() { |
| 269 | MutexLock unique_lock(pool_->lock_); |
| 270 | pool_->CheckNotPoolThreadUnlocked(); |
| 271 | while (IsActive()) { |
| 272 | not_running_cond_.Wait(); |
| 273 | } |
| 274 | } |
| 275 | |
| 276 | bool ThreadPoolToken::WaitUntil(const MonoTime& until) { |
| 277 | MutexLock unique_lock(pool_->lock_); |
no test coverage detected