SKALE-4586 Added Thread Pool

70c496f4 · kladko · f2bd2ae8 · 70c496f4
Unverified Commit 70c496f4 authored 3 years ago by kladko
Hide whitespace changes
Inline Side-by-side

Showing with 2 additions and 2 deletions

ZMQServer.cpp zmq_src/ZMQServer.cpp +2 -2

No files found.
--- a/zmq_src/ZMQServer.cpp
+++ b/zmq_src/ZMQServer.cpp
@@ -345,8 +345,8 @@ void ZMQServer::workerThreadProcessNextMessage(uint64_t _threadNumber) {
    try {

        while (!incomingQueue.at(_threadNumber)
-                .wait_dequeue_timed(element, std::chrono::milliseconds(100))) {
-
+                .wait_dequeue_timed(element, std::chrono::milliseconds(1000))) {
+            checkForExit();
        }

        result = element.first->process();