C++11 多线程编程指南：从基础使用到常见陷阱与线程池实现-拓冰建站

引言

C++11 标准引入了原生的多线程支持，通过<thread>头文件提供了跨平台的线程库，极大地简化了 C++ 多线程编程。本文将系统介绍 C++11 线程库的基本使用、常见易错点，并提供一个完整的线程池实现示例，帮助开发者避免多线程编程中的典型陷阱。

一、C++11 Thread 线程库的基本使用

1.1 线程创建与管理

C++11 通过std::thread类来创建和管理线程。基本用法如下：

#include<thread>// 创建线程并执行函数std::threadt(function_name,args...);// 线程开始运行// 等待线程完成（阻塞当前线程）t.join();// 分离线程，让它在后台运行（主线程不等待）t.detach();

1.2 基础示例：创建简单线程

#include<iostream>#include<thread>voidprint_message(){std::cout<<"Hello, world from thread!"<<std::endl;}intmain(){// 创建线程并执行 print_message 函数std::threadt(print_message);// 等待线程执行完成t.join();return0;}

1.3 传递参数给线程函数

向线程函数传递参数时需要注意引用传递的问题：

#include<iostream>#include<thread>#include<functional>// 包含 std::refvoidincrement(int&x){x++;// 对参数进行递增操作}intmain(){intnum=5;// 方式一：使用 std::ref 包装引用std::threadt1(std::ref(increment),std::ref(num));// 方式二：直接传递 std::refstd::threadt2(increment,std::ref(num));// 错误方式：直接传递值（会编译错误或产生副本）// std::thread t3(increment, num); // 错误！t1.join();t2.join();std::cout<<"After increment: "<<num<<std::endl;// 输出 7return0;}

关键点：

使用std::ref()包装引用参数
避免直接传递局部变量的引用（可能导致悬垂引用）

二、C++11 多线程编程常见陷阱

2.1 陷阱一：多线程访问局部变量

问题描述

在线程中访问局部变量是常见的错误，可能导致未定义行为或程序崩溃。

#include<iostream>#include<thread>std::thread t;voidfoo(int&x){std::this_thread::sleep_for(std::chrono::seconds(2));x+=1;std::cout<<x<<std::endl;}voidtest(){inta=1;// 局部变量t=std::thread(foo,std::ref(a));// test() 函数结束后，局部变量 a 被销毁}intmain(){test();t.join();// 此时访问的 a 已经失效！return0;}

运行结果可能

hq@nuc:~/java/my-project2$ ./a.out 32766 # 不可预测的值，或 Aborted (core dumped)

问题分析

内存安全问题：test()函数返回后，局部变量a被销毁，但线程仍在访问这块内存
未定义行为：访问已释放的内存导致不可预测的结果
平台差异：某些环境可能立即崩溃，某些可能暂时正常运行但结果错误

解决方案

// 将变量改为全局或静态变量inta=1;// 全局变量voidtest(){t=std::thread(foo,std::ref(a));// 现在安全了}

2.2 陷阱二：多线程访问已释放的内存

问题描述

通过指针在线程间共享数据时，如果指针指向的内存被提前释放，会导致严重问题。

#include<iostream>#include<thread>std::thread t;voidfoo(int*x){std::this_thread::sleep_for(std::chrono::seconds(2));std::cout<<*x<<std::endl;// 可能访问已释放内存*x+=1;std::cout<<*x<<std::endl;}intmain(){int*a=newint(20);t=std::thread(foo,a);deletea;// 提前释放内存t.join();return0;}

运行结果可能

(py37) hq@nuc:~/java/my-project2$ ./a.out 0 # 不可预测的值 1 # 或程序崩溃

正确实现：使用智能指针

#include<iostream>#include<thread>#include<memory>voidfoo(int*x){std::this_thread::sleep_for(std::chrono::seconds(2));std::cout<<*x<<std::endl;*x+=1;std::cout<<*x<<std::endl;}intmain(){// 使用 shared_ptr 确保内存安全std::shared_ptr<int>sharedPtr=std::make_shared<int>(42);// 方式一：使用 Lambda 捕获智能指针std::threadt1([sharedPtr](){foo(sharedPtr.get());});// 方式二：直接传递指针（智能指针确保对象存活）std::threadt2(foo,sharedPtr.get());t1.join();t2.join();return0;}

三、线程池实现与实践

3.1 线程池设计原理

线程池是一种重要的并发编程模式，它维护一组工作线程，等待分配并发执行任务。主要优点包括：

减少线程创建和销毁的开销
控制并发线程数量，避免资源耗尽
提高响应速度，任务可以立即执行

3.2 完整线程池实现

#include<iostream>#include<thread>#include<vector>#include<queue>#include<mutex>#include<condition_variable>#include<functional>#include<glog/logging.h>// 使用 Google Logging 替代 coutclassThreadPool{public:// 构造函数，创建指定数量的工作线程ThreadPool(size_t numThreads):stop(false){for(size_t i=0;i<numThreads;++i){workers.emplace_back([this]{while(true){std::function<void()>task;{// 获取任务队列锁std::unique_lock<std::mutex>lock(queueMutex);// 等待条件：线程池停止或任务队列非空condition.wait(lock,[this]{returnstop||!tasks.empty();});// 如果线程池停止且任务队列为空，线程退出if(stop&&tasks.empty()){return;}// 获取任务task=std::move(tasks.front());tasks.pop();}// 执行任务（在锁外执行，避免长时间持有锁）task();}});}}// 向线程池添加任务template<classF>voidenqueue(F&&f){{std::unique_lock<std::mutex>lock(queueMutex);// 任务队列已满时的处理（可根据需求调整）if(tasks.size()>1000){LOG(WARNING)<<"Task queue is full, dropping task";return;}tasks.emplace(std::forward<F>(f));}// 通知一个等待的线程有新任务condition.notify_one();}// 析构函数：安全停止所有线程~ThreadPool(){{std::unique_lock<std::mutex>lock(queueMutex);stop=true;}// 通知所有线程检查停止条件condition.notify_all();// 等待所有线程完成for(std::thread&worker:workers){if(worker.joinable()){worker.join();}}}private:std::vector<std::thread>workers;// 工作线程集合std::queue<std::function<void()>>tasks;// 任务队列std::mutex queueMutex;// 保护任务队列的互斥锁std::condition_variable condition;// 线程同步条件变量boolstop;// 停止标志};// 示例任务函数voidtaskFunction(inttaskId){// 使用日志替代 cout，避免多线程输出混乱LOG(INFO)<<"Task "<<taskId<<" is running in thread "<<std::this_thread::get_id();// 模拟任务执行时间std::this_thread::sleep_for(std::chrono::milliseconds(100));}intmain(){// 初始化 Google Logginggoogle::InitGoogleLogging("ThreadPoolDemo");// 创建包含 4 个工作线程的线程池ThreadPoolpool(4);// 提交 100 个任务到线程池for(inti=0;i<100;++i){pool.enqueue([i]{taskFunction(i);});}// 主线程等待足够时间让所有任务完成std::this_thread::sleep_for(std::chrono::seconds(3));LOG(INFO)<<"All tasks completed";return0;}