中断已处于条件变量等待调用中的提升线程

Interupt boost thread that is already in condition variable wait call

本文关键字：调用 等待 线程 变量 于条件 条件 中断      更新时间：2023-10-16

我正在使用boost进程间库创建服务器和客户端程序，以便在共享内存中传递opencv-mat对象。每个服务器和客户端进程都有两个boost线程，它们是boost:：thread_group的成员。一个处理命令行IO，另一个管理数据处理。共享内存访问使用boost:：interprocesscondition_variables进行同步。

由于这个程序涉及共享内存，我需要在退出之前进行一些手动清理。我的问题是，如果服务器提前终止，那么客户端上的处理线程会在wait()调用时阻塞，因为服务器负责发送通知。我需要以某种方式中断卡在wait()的线程，以启动共享内存销毁。我知道在线程上调用interrupt()(在我的情况下是thread_group.interrupt_all())会导致boost::thread_interrupted异常在到达中断点时抛出(如wait())，如果不处理，则会允许共享内存销毁继续进行。然而，当我试图在线程处于wait()时中断它时，似乎什么都没有发生。例如，这不会向命令行打印任何内容：

try {
shared_mat_header->new_data_condition.wait(lock);
} catch (...) {
std::cout << "Thread interrupt occurredn";
}

我一点也不确定，但似乎需要在线程进入wait()之前进行interrupt()调用才能引发异常。这是真的吗？如果没有，那么中断被condition_variable.wait()调用阻塞的提升线程的正确方法是什么？

感谢您的真知灼见。

编辑我接受了Chris Desjardins的回答，该回答没有直接回答问题，但具有预期效果。在这里，我正在翻译他的代码片段，以便与boost::interprocess条件变量一起使用，后者与boost::thread条件变量的语法略有不同：

while (_running) {
boost::system_time timeout = boost::get_system_time() + boost::posix_time::milliseconds(1);
if (shared_mat_header->new_data_condition.timed_wait(lock, timeout)) 
{
//process data
}
}

我更喜欢等待超时，然后检查等待调用的返回代码，看看它是否超时。事实上，我有一个我喜欢使用的线程模式来解决这种情况(以及c++中线程的其他常见问题)。

http://blog.chrisd.info/how-to-run-threads/

对你来说，要点是不要在线程中无限阻塞，所以你的线程看起来像这样：

while (_running == true)
{
if (shared_mat_header->new_data_condition.wait_for(lock, boost::chrono::milliseconds(1)) == boost::cv_status::no_timeout)
{
// process data
}
}

然后在析构函数中设置_running=false；并连接线程。

尝试使用"通知函数"。保留一个指向条件变量的指针并调用它，而不是中断线程。中断比通知电话要贵得多。

所以与其做

thread_group.interrupt_all()

改为调用

new_data_condition_pointer->notify_one()
相关文章：