diff --git a/src/storage/transaction/TransactionManager.cpp b/src/storage/transaction/TransactionManager.cpp index c0abedcc58e..f44dfd9e469 100644 --- a/src/storage/transaction/TransactionManager.cpp +++ b/src/storage/transaction/TransactionManager.cpp @@ -37,8 +37,6 @@ bool TransactionManager::start() { } scanPrimes(spaceId, partId, termId); } - monitorPoolStat(exec_.get(), "exec of Transaction Manager"); - statThread_ = std::thread(&TransactionManager::bgPrintPoolStat, this); return true; } @@ -74,9 +72,6 @@ void TransactionManager::stop() { void TransactionManager::join() { LOG(INFO) << "TransactionManager join()"; - if (statThread_.joinable()) { - statThread_.join(); - } exec_->stop(); } diff --git a/src/storage/transaction/TransactionManager.h b/src/storage/transaction/TransactionManager.h index 790fdd4f79d..f94156b92e6 100644 --- a/src/storage/transaction/TransactionManager.h +++ b/src/storage/transaction/TransactionManager.h @@ -116,7 +116,6 @@ class TransactionManager { void bgPrintPoolStat(); std::string dumpPoolStat(folly::ThreadPoolExecutor* pool, const std::string& msg); - std::thread statThread_; bool stop_{false}; std::vector> monPoolStats_;