| 73 | } |
| 74 | |
| 75 | int ThreadResourcePool::AddThreadAvailableCb(ThreadAvailableCb fn) { |
| 76 | unique_lock<mutex> l(lock_); |
| 77 | // The id is unique for each callback and is monotonically increasing. |
| 78 | int id = thread_callbacks_.size(); |
| 79 | thread_callbacks_.emplace_back(move(fn)); |
| 80 | num_callbacks_.Add(1); |
| 81 | return id; |
| 82 | } |
| 83 | |
| 84 | void ThreadResourcePool::RemoveThreadAvailableCb(int id) { |
| 85 | unique_lock<mutex> l(lock_); |