STM32F103标准库DHT11单总线驱动移植与时序避坑
2026/10/30 10:22:21
为了方便你系统化掌握,我为你将《C++并发编程实战》(C++ Concurrency in Action)第 2 章:线程管理(Thread Management)的核心内容梳理为一份完整的知识图谱与配套代码指南。
第 2 章的核心使命是解决:如何正确创建、控制、传递以及销毁线程?
std::thread对象即可启动线程。可传入普通函数、Lambda 表达式、仿函数(可调用对象)或类成员函数。std::thread对象销毁之前,必须显式决定是等待它(调用join())还是让它后台运行(调用detach())。否则,std::thread的析构函数会直接调用std::terminate()崩溃程序!join()之前发生异常抛出导致程序崩溃,通常采用 RAII 技术(如封装一个thread_guard类)来保证线程一定会被join()。#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;}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;}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;}std::thread::hardware_concurrency():获取 CPU 当前硬件支持的最大并发线程数(逻辑核心数)。若无法获取则返回0。*(注:这部分正是前面我们详细剖析的 *清单 2.8 原生并行版std::accumulate**的设计初衷,即依据系统能力划分任务块。)
std::thread对象获取:t.get_id()std::this_thread::get_id()#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;}| 概念 | 关键语法 / 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() | 提供唯一标识,可用于数据绑定和逻辑判断。 |