原始C++标准仅支持单线程编程。新的C++标准(称为C++11或C++0x)于2011年发布。在C++11中,引入了新的线程库。因此运行本文程序需要C++至少符合C++11标准。

2 连接和分离线程

在本章中,我们将讨论std::thread的连接和分离。

2.1 用std::thread::join()连接线程

一旦启动一个线程,则另一个线程可以等待该新线程完成。为此,还需要在std::thread对象上调用join()函数,即

std::thread th(funcPtr);
// Some Code
th.join();

让我们看一个例子,假设主线程必须启动10个工作线程,并且在启动所有这些线程之后,主函数将等待它们完成。连接所有线程后,主函数将继续。

#include <iostream>
#include <thread>
#include <algorithm>
#include <vector> class WorkerThread
{
public:
void operator()()
{
std::cout << "Worker Thread " << std::this_thread::get_id() << " is Executing" << std::endl;
}
};
int main()
{
// 创建多个线程
std::vector<std::thread> threadList;
for (int i = 0; i < 10; i++)
{
threadList.push_back(std::thread(WorkerThread()));
}
// Now wait for all the worker thread to finish i.e.
// Call join() function on each of the std::thread object
// 现在等待所有工作线程完成,即对每个std::thread对象调用join()函数
std::cout << "wait for all the worker thread to finish" << std::endl;
std::for_each(threadList.begin(), threadList.end(), std::mem_fn(&std::thread::join));
std::cout << "Exiting from Main Thread" << std::endl;
return 0;
}

输出为:

Worker Thread 12616 is ExecutingWorker Thread 10584 is Executing

Worker Thread Worker Thread 14696Worker Thread Worker Thread 15356Worker Thread 11228 is Executing
Worker Thread is Executing is Executing
9528 is Executing
Worker Thread
wait for all the worker thread to finish
Worker Thread 16312 is Executing
14448 is Executing77361908 is Executing is Executing
Exiting from Main Thread

2.2 使用std::thread::detach()分离线程

分离的线程也称为守护进程/后台线程。要分离线程,我们需要对std::thread对象调用std::detach()函数,即:

std::thread th(funcPtr);
th.detach();

调用detach()之后,std::thread对象不再与实际的执行线程关联。
注意在线程句柄上调用detach()和join()时要小心!!

情况1:永远不要在没有关联执行线程的std::thread对象上调用join()或detach()

    std::thread threadObj( (WorkerThread()) );
threadObj.join();
// 这将导致程序终止 It will cause Program to Terminate
threadObj.join();

当在线程对象上调用join()函数时,则当此join返回0时,则std::thread对象没有与其关联的线程。如果再次在该对象上调用join()函数,则将导致终止程序。同样,调用detach()可以使std::thread对象不与任何线程函数链接。在那种情况下,在std::thread对象上调用detach函数两次将导致程序终止。

    std::thread threadObj( (WorkerThread()) );
threadObj.detach();
// 这将导致程序终止 It will cause Program to Terminate
threadObj.detach();

因此,在调用join()或detach()之前,我们应该检查每次线程是否可连接,即

    std::thread threadObj( (WorkerThread()) );
if(threadObj.joinable())
{
std::cout<<"Detaching Thread "<<std::endl;
threadObj.detach();
}
if(threadObj.joinable())
{
std::cout<<"Detaching Thread "<<std::endl;
threadObj.detach();
} std::thread threadObj2( (WorkerThread()) );
if(threadObj2.joinable())
{
std::cout<<"Joining Thread "<<std::endl;
threadObj2.join();
}
if(threadObj2.joinable())
{
std::cout<<"Joining Thread "<<std::endl;
threadObj2.join();
}

情况2:不要忘记在具有关联的执行线程的std::Thread对象上调用Join或Detach
如果具有关联的执行线程的std::Thread对象没有调用Join或Detach,则在该对象的析构期间-否则它将终止程序。因为在析构内部-或者它检查线程是否仍然是可联接的,然后终止程序,即

#include <iostream>
#include <thread>
#include <algorithm>
class WorkerThread
{
public:
void operator()()
{
std::cout << "Worker Thread " << std::endl;
}
};
int main()
{
std::thread threadObj((WorkerThread()));
// Program will terminate as we have't called either join or detach with the std::thread object.
// Hence std::thread's object destructor will terminate the program
// 程序将终止,因为我们没有使用std::Thread对象调用Join或Detach。因此std::Thread的对象析构函数将终止程序
return 0;
}

输出为:

Worker Thread
程序崩溃

同样,在发生异常的情况下,我们不应忘记调用join()或detach()。为了防止这种情况,我们应该使用“资源获取初始化”( RESOURCE ACQUISITION IS INITIALIZATION,RAII),即

#include <thread>
#include <iostream> class ThreadRAII
{
std::thread & m_thread;
public:
ThreadRAII(std::thread & threadObj) : m_thread(threadObj)
{
}
~ThreadRAII()
{
// Check if thread is joinable then detach the thread
// 检查线程是否连接,然后分离线程
if (m_thread.joinable())
{
m_thread.detach();
}
}
};
void thread_function()
{
for (int i = 0; i < 10000; i++);
std::cout << "thread_function Executing" << std::endl;
} int main()
{
std::thread threadObj(thread_function); // If we comment this Line, then program will crash
// 如果我们注释此行,则程序将崩溃
ThreadRAII wrapperObj(threadObj);
return 0;
}

输出为:

thread_function Executing

2.3 参考

https://thispointer.com//c11-multithreading-part-3-carefully-pass-arguments-to-threads/

最新文章

  1. Apache Commons Collections
  2. UE4 Android打包 问题 记录笔记
  3. 解决hadoop启动后datanode无法启动问题
  4. vs2010 编译boost库
  5. jquery选择器效率优化问题
  6. CSS 框模型——规定了元素框处理元素内容、内边距、边框和外边距的方式
  7. Oracle数据库插入图片和读取图片
  8. 关于Linux平台malloc的写时拷贝(延迟分配)【转】
  9. Spring+SpringMVC+MyBatis深入学习及搭建(四)——MyBatis输入映射与输出映射
  10. easyUI前后台分页代码实现
  11. Discuz网警过滤关键词库
  12. SQL server分离和附加数据库
  13. C/C++ 动态存储分配 malloc calloc realloc函数的用法与区别
  14. day_6.5 py
  15. 网络基础之2——TCP/IP参考模型
  16. Yii2 数据操作Query Builder查询数据
  17. Emacs文件命令
  18. Android学习之AutoCompleteTextView
  19. Oracle备份恢复之逻辑备份
  20. [na]timewait优化

热门文章

  1. day48-JDBC和连接池04-2
  2. JDK 8之前日期和时间的API
  3. Linux三剑客sed
  4. JavaSPI详解
  5. 研发效能|DevOps 已死平台工程永存带来的焦虑
  6. 【k8s连载系列】k8s介绍
  7. 要写文档了,emmm,先写个文档工具吧——DocMarkdown
  8. tool1
  9. Python的几种lambda排序方法
  10. SQLSever事务