| 121 | } |
| 122 | |
| 123 | streamfx::util::threadpool::threadpool::threadpool(size_t minimum, size_t maximum) : _limits{minimum, maximum}, _workers_lock(), _worker_count(0), _workers(), _tasks_lock(), _tasks_cv(), _tasks() |
| 124 | { |
| 125 | // Spawn the minimum number of threads. |
| 126 | spawn(_limits.first); |
| 127 | } |
| 128 | |
| 129 | std::shared_ptr<streamfx::util::threadpool::task> streamfx::util::threadpool::threadpool::push(task_callback_t callback, task_data_t data /*= nullptr*/) |
| 130 | { |
nothing calls this directly
no outgoing calls
no test coverage detected