如何在不终止程序的情况下停止std::线程的运行

How to stop an std::thread from running, without terminating the program

本文关键字：运行 std 线程 情况下 终止程序      更新时间：2023-10-16

我正在尝试从C++11学习std::threads，以创建线程系统。

我想知道是否有一种方法可以在不终止整个程序的情况下阻止线程运行（不是休眠，而是真正破坏线程）。

我知道std::join存在，但这迫使线程等待所有线程返回。

有其他方法可以解决这个问题吗？（例如，在不阻塞线程的情况下创建ThreadPool类？）

也许这个线程工具会帮助你：

#include <boost/thread.hpp>
#include <boost/phoenix.hpp>
#include <boost/optional.hpp>
using namespace boost;
using namespace boost::phoenix::arg_names;
boost::atomic_size_t counter(0ul);
class thread_pool
{
  private:
      mutex mx;
      condition_variable cv;
      typedef function<void()> job_t;
      std::deque<job_t> _queue;
      thread_group pool;
      boost::atomic_bool shutdown;
      static void worker_thread(thread_pool& q)
      {
          while (optional<job_t> job = q.dequeue())
              (*job)();
      }
  public:
      thread_pool() : shutdown(false) {
          for (unsigned i = 0; i < boost::thread::hardware_concurrency(); ++i)
              pool.create_thread(bind(worker_thread, ref(*this)));
      }
      void enqueue(job_t job) 
      {
          lock_guard<mutex> lk(mx);
          _queue.push_back(job);
          cv.notify_one();
      }
      optional<job_t> dequeue() 
      {
          unique_lock<mutex> lk(mx);
          namespace phx = boost::phoenix;
          cv.wait(lk, phx::ref(shutdown) || !phx::empty(phx::ref(_queue)));
          if (_queue.empty())
              return none;
          job_t job = _queue.front();
          _queue.pop_front();
          return job;
      }
      ~thread_pool()
      {
          shutdown = true;
          {
              lock_guard<mutex> lk(mx);
              cv.notify_all();
          }
          pool.join_all();
      }
};

使用示例：live On Coliru

C++std::thread类实际上只是一个最小的接口，它位于一些更完整的实现定义的线程包之上。因此，它只定义了少量的功能——创建新的线程detach和join。基本上就是这样——没有标准的方法来管理、调度、停止/启动/终止线程或做其他事情。

有一个native_handle方法，它返回一个实现定义的类型，根据实现的不同，该类型可能用于执行您想要的操作。

没有办法非协作地阻止线程使用标准C++运行。这并不意味着这是不可能的，但您可能需要回到您的系统本机句柄。

对于符合标准的方式，您可以使用同步原语（例如std::atomic<bool>）从外部设置终止标志，并在线程内读取它。但它仍然必须是独立完成的线程。

相关文章：