diff --git a/Net/src/TCPServerDispatcher.cpp b/Net/src/TCPServerDispatcher.cpp index 5055dc244..efb8b2a31 100644 --- a/Net/src/TCPServerDispatcher.cpp +++ b/Net/src/TCPServerDispatcher.cpp @@ -173,7 +173,10 @@ void TCPServerDispatcher::stop() FastMutex::ScopedLock lock(_mutex); _stopped = true; _queue.clear(); - _queue.enqueueNotification(new StopNotification); + for (int i = 0; i < _threadPool.allocated(); i++) + { + _queue.enqueueNotification(new StopNotification); + } }