From 6518c2c67d4395e3676f841bcad5c00cdaf35e84 Mon Sep 17 00:00:00 2001 From: Yunjia Wang Date: Tue, 9 Jul 2019 10:05:10 -0700 Subject: [PATCH] Remove ThreadPoolWorker GABC --- src/core/lib/iomgr/executor/threadpool.cc | 2 +- src/core/lib/iomgr/executor/threadpool.h | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/core/lib/iomgr/executor/threadpool.cc b/src/core/lib/iomgr/executor/threadpool.cc index 82b1724c23a..deeadc0f758 100644 --- a/src/core/lib/iomgr/executor/threadpool.cc +++ b/src/core/lib/iomgr/executor/threadpool.cc @@ -99,7 +99,7 @@ ThreadPool::ThreadPool(int num_threads, const char* thd_name, } ThreadPool::~ThreadPool() { - shut_down_.Store(false, MemoryOrder::RELEASE); + shut_down_.Store(true, MemoryOrder::RELEASE); for (int i = 0; i < num_threads_; ++i) { queue_->Put(nullptr); diff --git a/src/core/lib/iomgr/executor/threadpool.h b/src/core/lib/iomgr/executor/threadpool.h index 3bc79aa6c3c..f0c54104ef1 100644 --- a/src/core/lib/iomgr/executor/threadpool.h +++ b/src/core/lib/iomgr/executor/threadpool.h @@ -79,7 +79,7 @@ class ThreadPoolWorker { void Start() { thd_.Start(); } void Join() { thd_.Join(); } - GRPC_ABSTRACT_BASE_CLASS + // GRPC_ABSTRACT_BASE_CLASS private: // struct for tracking stats of thread