| 19 | } |
| 20 | |
| 21 | void HpcThreadPool::activate() { |
| 22 | { |
| 23 | std::lock_guard<std::mutex> _l(queue_mutex_); |
| 24 | available_task_slots_++; |
| 25 | available_task_slots_old_++; |
| 26 | } |
| 27 | |
| 28 | // Tell somebody we can work |
| 29 | condition_.notify_all(); |
| 30 | } |
| 31 | |
| 32 | void HpcThreadPool::deactivate() { |
| 33 | available_task_slots_--; |