From d6cb38d0f31fa64f73a725768c2552e88001f764 Mon Sep 17 00:00:00 2001
From: chejinge <chejinge@360.cn>
Date: Wed, 5 Jun 2024 20:37:09 +0800
Subject: [PATCH] fix

---
 src/pika_server.cc | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/src/pika_server.cc b/src/pika_server.cc
index 8fab94ef3..811a85b1d 100644
--- a/src/pika_server.cc
+++ b/src/pika_server.cc
@@ -212,6 +212,9 @@ void PikaServer::SetSlowCmdThreadPoolFlag(bool flag) {
                  << (ret == net::kCreateThreadError ? ": create thread error " : ": other error");
     }
   } else {
+    while (SlowCmdThreadPoolCurQueueSize() != 0) {
+      std::this_thread::sleep_for(std::chrono::milliseconds(100));
+    }
     pika_slow_cmd_thread_pool_->stop_thread_pool();
   }
 }