29

可能重复：
C++0x 线程中断

我试图通过使用它的线程对象来杀死/停止一个 c++ std::thread。

我们应该怎么做？

4

2 回答 2

42

@bamboon 的回答很好，但我觉得这值得更强有力的声明。

无论您使用什么语言，您的程序都会获取和释放资源：内存、文件描述符……对于一次性触发的简单程序，泄漏资源无关紧要：当程序结束时，现代操作系统会自动收回资源; 然而，对于长时间运行的程序，基本要求是不泄漏资源，或者至少不重复。

因此，你应该从一开始就被教导，当你获得一个资源时，你必须确保它在某一时刻被释放：

void foo(int i) {
    int* array = malloc(sizeof(int) * i);

    /* do something */

    free(array);
}

所以，问自己一个问题：

  • 当我杀死程序时会发生什么？
  • 当我杀死线程时会发生什么？

好吧，正如我们所说，当一个程序结束时，操作系统会收集资源，所以假设（这是一些假设）你没有在另一个系统上获取资源，或者这个系统得到了很好的保护，免受这种滥用，没有伤害，没有犯规。

但是，当你杀死一个线程时，程序仍然运行，因此操作系统不会收集资源。您泄漏了内存，您锁定了一个无法再解锁的写入文件，......您不应杀死线程。

高级语言有办法处理这个问题：异常。因为程序无论如何都应该是异常安全的，Java（例如）将通过暂停线程来终止线程，在执行点抛出异常，然后轻轻展开堆栈。然而，在 C++ 中还没有这样的工具。

这是不可能的吗？不，显然不是。实际上，您可以完美地重用相同的想法：

  • 封装std::thread，interruptible_thread类还将包含一个中断标志
  • 在启动时将标志的地址传递给std::thread它，并将其以线程本地方式存储
  • 使用检查点检测您的代码，检查是否设置了中断标志，以及何时抛出异常

那是：

// Synopsis
class interrupt_thread_exception;
class interruptible_thread;
void check_for_interrupt();

// Interrupt exception
class interrupt_thread_exception: public virtual std::exception {
public:
    virtual char const* what() const override { return "interrupt"; }
}; // class interrupt_thread_exception

// Interruptible thread
class interruptible_thread {
public:
    friend void check_for_interrupt();

    template <typename Function, typename... Args>
    interruptible_thread(Function&& fun, Args&&... args):
        _thread([](std::atomic_bool& f, Function&& fun, Args&&... args) {
                    _flag_ref = &f; fun(std::forward<Args>(args)...);
                },
                _flag,
                std::forward<Function>(fun),
                std::forward<Args>(args)...)
    {}

    bool stopping() const { return _flag.load(); }

    void stop() { _flag.store(true); }

private:
    static thread_local std::atomic_bool* _flag_ref = nullptr;

    std::atomic_bool _flag = false;
    std::thread _thread;
}; // class interruptible_thread

// Interruption checker
inline void check_for_interrupt() noexcept(false) {
    if (not interruptible_thread::_flag_ref) { return; }
    if (not interruptible_thread::_flag_ref->load()) { return; }

    throw interrupt_thread_exception();
} // check_for_interrupt

现在你可以在你的线程代码中添加适当的中断检查。

于 2012-12-15T15:14:22.823 回答
32

你不能。

std::threads不可中断。您可以使用boost::thread提供此功能的哪个。

Boost 通过定义“中断点”来实现这一点，如果线程被中断并到达这样的点，线程将在该点上结束。

尽管如此，大多数时候考虑重新设计可能是实现您想要实现的目标的最简洁和最简单的方法。

如果您仍在寻找可中断线程的 C++11 实现，请查看 Anthony Williams（boost 线程的所有者）一书“C++ Concurrency in Action”。他经历了如何实现这样的事情的基本实现。

std::thread::native_handle使您可以访问可能支持中断的平台特定的底层线程句柄，但是这种方法使您的代码不可移植并且可能以任何方式都不干净。

于 2012-12-15T14:41:55.970 回答