C++中的多线程:连接线程的正确方法
Multithreading in C++: The correct way to join threads
我是多线程的新手,所以任何建议将不胜感激。以下程序接收整数向量(例如 1 2 3 4 5 6 7(,并将每个整数作为线程进行处理。我想知道我加入线程的方法是否正确,以及我是否可以进行任何改进。
我希望我的解释清楚!这是我的代码片段。这不是完整的代码,我只是确保我走正确的路:
//vector's name is 'inputs' and it contains integers
for (int unsigned i = 0; i < inputs.size(); i++) {
thread thread_obj(thread_function, inputs.at(i));
thread_obj.detach();
}
for (int unsigned i = 0; i < inputs.size(); i++) {
thread_obj.join();
}
您的代码具有未定义的行为,因此不,这是不正确的。 这里的问题是,只有在joinable()
true
并且因为您调用了detach()
,joinable()
才能调用join()
,因此false
。
好消息是它真的是一个非常简单的修复。 您只需要删除对detach
的调用。 要完成代码,只需填充一个线程向量,然后像
std::vector<std::thread> threads;
threads.reserve(inputs.size());
for (int unsigned i = 0; i < inputs.size(); i++) {
threads.push_back(std::thread{thread_function, inputs.at(i)};
}
// now all threads are running, or waiting to run
for (int unsigned i = 0; i < inputs.size(); i++) {
threads[i].join();
}
// now all threads have been joined
相关文章:
- 从不同线程使用int64的不同字节安全吗
- 删除一个线程上有数百万个字符串的大型哈希映射会影响另一个线程的性能
- 在C++中使用cURL和多线程
- 为什么我的C#代码在调用回C++COM直到Task时会暂停.等待/线程.加入
- 在cuda线程之间共享大量常量数据
- 如何将元素添加到数组的线程安全函数?
- 线程,如果else语句,都是错误的上下文切换后,会发生什么
- C++Boost Asio Pool线程,带有lambda函数和传递引用变量
- Qt C++静态thread_local QNetworkAccessManager是线程应用程序的好选择吗
- 异常属于C++中的线程还是进程
- C++中的线程安全删除
- C++使用params创建线程函数会导致转换错误
- 类与私有变量的其他类之间的线程安全性
- CoInitialize()在单独的线程上崩溃而不返回
- c++中的线程池
- 线程之间的布尔停止信号
- 为什么std::async使用同一个线程运行函数
- 用于矢量处理的多个线程
- C++中的多线程:连接线程的正确方法
- 连接线程(阻塞调用线程直到线程终止)和普通函数调用之间的区别是什么