summaryrefslogtreecommitdiff
path: root/grpc/src/cpp/server/dynamic_thread_pool.cc
diff options
context:
space:
mode:
Diffstat (limited to 'grpc/src/cpp/server/dynamic_thread_pool.cc')
-rw-r--r--grpc/src/cpp/server/dynamic_thread_pool.cc4
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_);
}