diff options
| -rw-r--r-- | src/server/PreProcessor.cpp | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/src/server/PreProcessor.cpp b/src/server/PreProcessor.cpp index 6c514f00..e26ebcdc 100644 --- a/src/server/PreProcessor.cpp +++ b/src/server/PreProcessor.cpp @@ -114,7 +114,11 @@ void PreProcessor::run() { ThreadManager::set_flag(THREAD_PRE_PROCESS); - while (_sem.wait() && !_exit_flag) { + while (!_exit_flag) { + if (!_sem.timed_wait(1000)) { + continue; + } + Event* const ev = _prepared_back.load(); if (!ev) { return; |