diff options
Diffstat (limited to 'grpc/src/cpp/server/dynamic_thread_pool.cc')
-rw-r--r-- | grpc/src/cpp/server/dynamic_thread_pool.cc | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/grpc/src/cpp/server/dynamic_thread_pool.cc b/grpc/src/cpp/server/dynamic_thread_pool.cc index 4131dc66..e96dc4c4 100644 --- a/grpc/src/cpp/server/dynamic_thread_pool.cc +++ b/grpc/src/cpp/server/dynamic_thread_pool.cc @@ -68,7 +68,7 @@ void DynamicThreadPool::ThreadFunc() { if (!callbacks_.empty()) { auto cb = callbacks_.front(); callbacks_.pop(); - lock.Unlock(); + lock.Release(); cb(); } else if (shutdown_) { break; @@ -97,7 +97,7 @@ void DynamicThreadPool::ReapThreads(std::list<DynamicThread*>* tlist) { DynamicThreadPool::~DynamicThreadPool() { grpc_core::MutexLock lock(&mu_); shutdown_ = true; - cv_.Broadcast(); + cv_.SignalAll(); while (nthreads_ != 0) { shutdown_cv_.Wait(&mu_); } |