| 9 | using concurrencpp::worker_thread_executor; |
| 10 | |
| 11 | worker_thread_executor::worker_thread_executor(const std::function<void(std::string_view thread_name)>& thread_started_callback, |
| 12 | const std::function<void(std::string_view thread_name)>& thread_terminated_callback) : |
| 13 | derivable_executor<concurrencpp::worker_thread_executor>(details::consts::k_worker_thread_executor_name), |
| 14 | m_private_atomic_abort(false), m_semaphore(0), m_atomic_abort(false), m_abort(false), |
| 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( |
nothing calls this directly
no outgoing calls
no test coverage detected