MCPcopy Create free account
hub / github.com/bloomberg/quantum / terminate

Method terminate

quantum/impl/quantum_task_queue_impl.h:349–362  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

347}
348
349inline
350void TaskQueue::terminate()
351{
352 bool value{false};
353 if (_terminated.compare_exchange_strong(value, true))
354 {
355 {
356 std::unique_lock<std::mutex> lock(_notEmptyMutex);
357 _isInterrupted = true;
358 }
359 _notEmptyCond.notify_all();
360 _thread->join();
361 }
362}
363
364inline
365IQueueStatistics& TaskQueue::stats()

Callers 3

runMethod · 0.45
doDequeueMethod · 0.45
handleSuccessMethod · 0.45

Calls 1

joinMethod · 0.80

Tested by

no test coverage detected