fix bug

gwq5210 · Aug 16, 2022 · bfb4814 · bfb4814
1 parent e669feb
commit bfb4814
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/src/gtl/thread/thread_pool.cc b/src/gtl/thread/thread_pool.cc
@@ -6,12 +6,11 @@ bool ThreadPool::Start(size_t thread_count) {
  for (size_t i = 0; i < thread_count; ++i) {
  threads_.emplace_back([this]() { this->Run(); });
  }
- stop_ = false;
  return true;
 }
 
 bool ThreadPool::AddTask(std::function<void(void)>&& task) {
- if (stop_) {
+ if (threads_.empty()) {
  return false;
  }
  mutex_.Lock();

diff --git a/src/gtl/thread/thread_pool.h b/src/gtl/thread/thread_pool.h
@@ -52,7 +52,7 @@ class ThreadPool : public IThreadPool {
 
  void Run();
 
- std::atomic_bool stop_{true};
+ std::atomic_bool stop_{false};
  Mutex mutex_;
  CondVar cond_var_;
  Vector<Thread> threads_;