BlockStorage/repertory
1
0
Fork 0
Code Issues 3 Pull Requests Releases 9 Wiki Activity

shutdown fix

Browse Source
This commit is contained in:
sgraves76
2025-10-04 14:08:23 -05:00
parent 756f701fdb
commit 1ca93d52d7
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
repertory/librepertory/src/comm/packet/client_pool.cpp
View File

@@ -36,11 +36,15 @@ client_pool::pool::work_queue::work_queue() {
} }
client_pool::pool::work_queue::~work_queue() { client_pool::pool::work_queue::~work_queue() {
shutdown = true;
unique_mutex_lock lock(mutex);
notify.notify_all();
lock.unlock();
if (thread->joinable()) { if (thread->joinable()) {
thread->join(); thread->join();
} }
thread.reset();
} }
void client_pool::pool::work_queue::work_thread() { void client_pool::pool::work_queue::work_thread() {