mirror of
https://github.com/Icinga/icinga2.git
synced 2025-04-08 17:05:25 +02:00
ThreadPool#Stop(): discard non-processed queue items
This commit is contained in:
parent
7b39591c6b
commit
30e6d0f809
@ -73,6 +73,7 @@ void ThreadPool::Stop()
|
||||
for (auto& queue : m_Queues) {
|
||||
boost::mutex::scoped_lock lock(queue.Mutex);
|
||||
queue.Stopped = true;
|
||||
queue.Items.clear();
|
||||
queue.CV.notify_all();
|
||||
}
|
||||
|
||||
|
Loading…
x
Reference in New Issue
Block a user