ThreadPool#Stop(): discard non-processed queue items

diff --git a/lib/base/threadpool.cpp b/lib/base/threadpool.cpp
index 1dad249bc5b6927b1ca7a00888069ed252c38301..b6b01ea785ac9781fc8b74df031fde0962394285 100644 (file)
--- 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();
        }