From: Alexander A. Klimov Date: Mon, 3 Dec 2018 15:38:52 +0000 (+0100) Subject: ThreadPool#Stop(): discard non-processed queue items X-Git-Tag: v2.11.0-rc1~277^2 X-Git-Url: https://granicus.if.org/sourcecode?a=commitdiff_plain;h=30e6d0f809c47de4204b949263fa209da42e975c;p=icinga2 ThreadPool#Stop(): discard non-processed queue items --- diff --git a/lib/base/threadpool.cpp b/lib/base/threadpool.cpp index 1dad249bc..b6b01ea78 100644 --- a/lib/base/threadpool.cpp +++ b/lib/base/threadpool.cpp @@ -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(); }