《C++并发编程实战》(C++ Concurrency in Action)第 2 章:线程管理(Thread Management)的核心内容梳理为一份完整的知识图谱与配套代码指南
为了方便你系统化掌握,我为你将《C++并发编程实战》(C++ Concurrency in Action)第 2 章:线程管理(Thread Management)的核心内容梳理为一份完整的知识图谱与配套代码指南。
第 2 章的核心使命是解决:如何正确创建、控制、传递以及销毁线程?
📚 目录框架
- 线程的基本启动与生命周期管理
- 向线程传递参数
- 转移线程所有权(Move 语义)
- 运行时决定线程数量(硬件并发度)
- 识别线程(Thread ID)
1. 线程的基本启动与生命周期管理
核心概念
- 启动线程:通过构造
std::thread对象即可启动线程。可传入普通函数、Lambda 表达式、仿函数(可调用对象)或类成员函数。 - 生命周期约束:在
std::thread对象销毁之前,必须显式决定是等待它(调用join())还是让它后台运行(调用detach())。否则,std::thread的析构函数会直接调用std::terminate()崩溃程序! - RAII 思想管理线程:为了防止在
join()之前发生异常抛出导致程序崩溃,通常采用 RAII 技术(如封装一个thread_guard类)来保证线程一定会被join()。
📁 示例代码:启动方式与 RAII 防护
#include<iostream>#include<thread>#include<stdexcept>// RAII 包装类:确保线程在作用域结束时安全 joinclassthread_guard{std::thread&t;public:explicitthread_guard(std::thread&t_):t(t_){}~thread_guard(){if(t.joinable()){t.join();// 析构时自动等待线程结束}}// 禁用拷贝构造和赋值thread_guard(thread_guardconst&)=delete;thread_guard&operator=(thread_guardconst&)=delete;};voiddo_background_work(){std::cout<<"[子线程] 正在后台干活...\n";}structTask{voidoperator()()const{std::cout<<"[仿函数线程] 正在运行...\n";}};intmain(){// 1. 普通函数启动std::threadt1(do_background_work);thread_guardg1(t1);// 用 RAII 保护 t1// 2. 仿函数启动 (注意 C++ 的 C++'s most vexing parse,推荐使用 {} 避免被识别为函数声明)std::thread t2{Task()};thread_guardg2(t2);// 3. Lambda 表达式启动std::threadt3([](){std::cout<<"[Lambda 线程] 正在运行...\n";});thread_guardg3(t3);std::cout<<"[主线程] 执行完毕,RAII 会安全回收所有线程。\n";return0;}2. 向线程函数传递参数
核心概念
- 默认拷贝:
std::thread的构造函数会无视函数形参类型,默认将参数拷贝到线程的独立存储空间中。 - 引用传递:如果函数形参是引用(如
int&),直接传参会导致编译错误或未定义行为。必须使用std::ref()显式包装。 - 成员函数:传递类的成员函数时,第一个参数必须是成员函数指针(如
&MyClass::func),第二个参数是类对象的指针或引用。
📁 示例代码:传参技巧与引用传递
#include<iostream>#include<thread>#include<string>#include<functional>// std::refclassWorker{public:voiddo_work(intid,conststd::string&name){std::cout<<"[成员函数线程] Worker ID: "<<id<<", Name: "<<name<<"\n";}};voidupdate_value(int&value){value+=100;}intmain(){// 1. 传递引用参数(必须使用 std::ref)intdata=42;std::threadt1(update_value,std::ref(data));t1.join();std::cout<<"[主线程] 更新后的 data = "<<data<<" (期望 142)\n";// 2. 调用类的成员函数Worker worker;std::threadt2(&Worker::do_work,&worker,1,"Alpha");t2.join();return0;}3. 转移线程所有权(Move 语义)
核心概念
- 不可拷贝,可移动:
std::thread是独占资源的对象(类似于std::unique_ptr)。你不能复制一个线程,但可以使用std::move()转移它的所有权。 - 转移条件:不能向一个已经关联着活跃线程的
std::thread对象赋值,否则会触发std::terminate()。
📁 示例代码:线程所有权转移与容器管理
#include<iostream>#include<thread>#include<vector>#include<utility>// std::movevoidworker_func(intid){std::cout<<"线程 "<<id<<" 正在运行\n";}intmain(){// 1. 所有权转移std::threadt1(worker_func,1);// 将 t1 的所有权转移给 t2,此时 t1 变为 empty 状态std::thread t2=std::move(t1);if(!t1.joinable()){std::cout<<"t1 已经不再关联任何线程。\n";}t2.join();// 由 t2 来负责等待结束// 2. 利用 Move 语义管理线程容器(批量生成与回收)std::vector<std::thread>threads;for(inti=0;i<3;++i){threads.emplace_back(worker_func,i+10);// 内部自动 move 构造}for(auto&t:threads){if(t.joinable()){t.join();}}return0;}4. 运行时决定线程数量与分块计算
核心概念
std::thread::hardware_concurrency():获取 CPU 当前硬件支持的最大并发线程数(逻辑核心数)。若无法获取则返回0。- 任务分割(Data Parallelism):根据硬件核心数和数据总量,将任务切分给各个线程处理,避免过度竞争(Oversubscription)。
*(注:这部分正是前面我们详细剖析的 *清单 2.8 原生并行版std::accumulate**的设计初衷,即依据系统能力划分任务块。)
5. 线程识别(Thread ID)
核心概念
- 获取方式:
- 通过
std::thread对象获取:t.get_id() - 在当前线程内部获取:
std::this_thread::get_id()
- 作用:用于判断某个操作是否在特定线程(如主线程/GUI 线程)执行,或作为数据结构(如哈希表)中的 Key 来关联特定线程的数据。
📁 示例代码:线程标识符的应用
#include<iostream>#include<thread>std::thread::id main_thread_id;voidcheck_thread(){if(std::this_thread::get_id()==main_thread_id){std::cout<<"当前处于【主线程】中。\n";}else{std::cout<<"当前处于【子线程】中,ID: "<<std::this_thread::get_id()<<"\n";}}intmain(){main_thread_id=std::this_thread::get_id();check_thread();// 在主线程中检查std::threadt(check_thread);// 在子线程中检查t.join();return0;}💡 第 2 章核心要点总结表
| 概念 | 关键语法 / API | 核心注意事项 |
|---|---|---|
| 生命周期 | t.join()/t.detach() | 析构前必须显式调用其一,建议采用RAII保护。 |
| 参数传递 | std::ref(arg) | 引用传参必须显式使用std::ref,防止拷贝引发错误。 |
| 所有权 | std::move(t) | std::thread不可拷贝,支持移动。 |
| 并发度 | std::thread::hardware_concurrency() | 获取物理/逻辑 CPU 核心数,返回值可能为 0。 |
| 线程 ID | std::this_thread::get_id() | 提供唯一标识,可用于数据绑定和逻辑判断。 |