From: Alexander A. Klimov <alexander.klimov@icinga.com>
Date: Mon, 3 Dec 2018 15:38:52 +0000 (+0100)
Subject: ThreadPool#Stop(): discard non-processed queue items
X-Git-Tag: v2.10.3~58
X-Git-Url: https://granicus.if.org/sourcecode?a=commitdiff_plain;h=797ecd1539c91d3dd02dc7d164ce602c52a6f802;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();
 	}