thread.join()超时
thread.join()超时
提问于 2012-03-31 02:20:38
是否可以为调用std::thread::join()设置超时时间？我希望处理线程运行时间过长或终止线程的情况。我可能会为多个线程(比如最多30个线程)执行此操作。
最好不要boost，但如果这是最好的方式，我会对boost解决方案感兴趣。
回答 4
Stack Overflow用户
回答已采纳
发布于 2012-03-31 03:14:13
std::thread::join()没有超时。但是，您可以将std::thread::join()仅仅看作是一个方便的函数。使用condition_variable，您可以在线程之间创建非常丰富的通信和协作，包括计时等待。例如：
#include <chrono>
#include <thread>
#include <iostream>
int thread_count = 0;
bool time_to_quit = false;
std::mutex m;
std::condition_variable cv;
void f(int id)
{
{
std::lock_guard<std::mutex> _(m);
++thread_count;
}
while (true)
{
{
std::lock_guard<std::mutex> _(m);
std::cout << "thread " << id << " working\n";
}
std::this_thread::sleep_for(std::chrono::milliseconds(250));
std::lock_guard<std::mutex> _(m);
if (time_to_quit)
break;
}
std::lock_guard<std::mutex> _(m);
std::cout << "thread ended\n";
--thread_count;
cv.notify_all();
}
int main()
{
typedef std::chrono::steady_clock Clock;
std::thread(f, 1).detach();
std::thread(f, 2).detach();
std::thread(f, 3).detach();
std::thread(f, 4).detach();
std::thread(f, 5).detach();
auto t0 = Clock::now();
auto t1 = t0 + std::chrono::seconds(5);
std::unique_lock<std::mutex> lk(m);
while (!time_to_quit && Clock::now() < t1)
cv.wait_until(lk, t1);
time_to_quit = true;
std::cout << "main ending\n";
while (thread_count > 0)
cv.wait(lk);
std::cout << "main ended\n";
}在这个例子中，main启动了几个线程来做工作，所有这些线程偶尔都会检查是否到了在互斥锁(也可以是原子互斥锁)下退出的时候。主线程还监视是否到了退出的时间(如果线程完成了所有工作)。如果main耗尽了耐心，他只会声明是时候退出了，然后等待所有线程在退出之前执行任何必要的清理。
Stack Overflow用户
发布于 2014-07-26 02:49:42
您可以使用std::async()为您提供std::future<>，并且可以在std::future上执行定时等待，而不是显式地使用线程
Stack Overflow用户
发布于 2014-07-26 01:20:00
对于Boost，现在不推荐使用timed_join()。请改用try_join_for()：
myThread.try_join_for(boost::chrono::milliseconds(8000))页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/9948420
复制相关文章
相似问题
腾讯云开发者
