| 137 | } |
| 138 | |
| 139 | void SCQueueSynchronizer::start_worker(std::thread thread) { |
| 140 | mgb_assert(!m_worker_started); |
| 141 | m_worker_started = true; |
| 142 | m_worker_thread = std::move(thread); |
| 143 | } |
| 144 | |
| 145 | void SCQueueSynchronizer::producer_add() { |
| 146 | m_wait_finish_called = false; |
no outgoing calls