| 82 | } |
| 83 | |
| 84 | void ThreadResourcePool::RemoveThreadAvailableCb(int id) { |
| 85 | unique_lock<mutex> l(lock_); |
| 86 | DCHECK(!thread_callbacks_[id].empty()); |
| 87 | DCHECK_GT(num_callbacks_.Load(), 0); |
| 88 | thread_callbacks_[id].clear(); |
| 89 | num_callbacks_.Add(-1); |
| 90 | } |
| 91 | |
| 92 | void ThreadResourcePool::InvokeCallbacks() { |
| 93 | // We need to grab a lock before issuing the callbacks to prevent the |