| 15 | m_thread_started_callback(thread_started_callback), m_thread_terminated_callback(thread_terminated_callback) {} |
| 16 | |
| 17 | void concurrencpp::worker_thread_executor::make_os_worker_thread() { |
| 18 | m_thread = details::thread( |
| 19 | details::make_executor_worker_name(name), |
| 20 | [this] { |
| 21 | work_loop(); |
| 22 | }, |
| 23 | m_thread_started_callback, |
| 24 | m_thread_terminated_callback); |
| 25 | } |
| 26 | |
| 27 | bool worker_thread_executor::drain_queue_impl() { |
| 28 | while (!m_private_queue.empty()) { |