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

This reverts commit 797ecd1539c91d3dd02dc7d164ce602c52a6f802.

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