0

0

C++怎么实现一个线程池_C++线程池设计与实现方法

冰火之心

冰火之心

发布时间:2025-11-16 17:32:02

|

925人浏览过

|

来源于php中文网

原创

线程池通过复用线程减少开销,核心包括任务队列、线程集合、互斥锁与条件变量;使用std::function封装任务,通过enqueue提交,工作线程循环取任务执行;析构时需安全停止并join所有线程;典型应用创建4线程池提交8个计算平方任务,结果通过future获取,关键在于正确管理同步与线程生命周期。

c++怎么实现一个线程池_c++线程池设计与实现方法

线程池的核心目标是复用线程,避免频繁创建和销毁带来的开销。在C++中实现线程池,关键在于任务队列管理、线程调度与同步控制。下面介绍一种简洁高效的实现方式。

线程池的基本结构

一个典型的线程池包含以下几个部分:

  • 任务队列:存放待执行的任务(通常为函数对象)
  • 线程集合:一组工作线程,不断从任务队列中取出任务执行
  • 互斥锁与条件变量:保证多线程环境下任务队列的线程安全
  • 控制开关:用于优雅关闭线程池

任务使用std::function封装,支持lambda、函数指针或仿函数。

任务提交与执行机制

用户通过enqueue方法提交任务,线程池将其放入队列。空闲线程会被条件变量唤醒,取任务执行。

立即学习C++免费学习笔记(深入)”;

关键点在于使用std::condition_variable实现阻塞等待,避免忙等。

示例代码片段:

template 
auto enqueue(F&& f) -> std::future {
    using return_type = decltype(f());
    auto task = std::make_shared>(std::forward(f));
    std::future res = task->get_future();
    {
        std::unique_lock lock(queue_mutex);
        if (stop) throw std::runtime_error("enqueue on stopped thread pool");
        tasks.emplace([task]() { (*task)(); });
    }
    condition.notify_one();
    return res;
}

线程管理与析构处理

构造函数中启动指定数量的工作线程,每个线程运行一个死循环,从任务队列获取任务。

Designify
Designify

拖入图片便可自动去除背景✨

下载

析构时设置停止标志,唤醒所有线程,然后调用join()等待其退出。

注意:必须确保所有线程安全退出,否则可能导致资源泄漏或程序卡死。

典型工作线程逻辑:

while (true) {
    std::function task;
    {
        std::unique_lock lock(queue_mutex);
        condition.wait(lock, [this] { return stop || !tasks.empty(); });
        if (stop && tasks.empty()) return;
        task = std::move(tasks.front());
        tasks.pop();
    }
    task();
}

使用示例与注意事项

创建4个线程的线程池:

ThreadPool pool(4);
std::vector> results;
for (int i = 0; i < 8; ++i) {
    results.emplace_back(pool.enqueue([i] {
        std::this_thread::sleep_for(std::chrono::seconds(1));
        return i * i;
    }));
}
for (auto& result : results)
    std::cout << result.get() << ' ';

输出结果为平方数序列。注意任务返回值通过std::future获取。

使用时避免提交长时间阻塞任务,影响整体吞吐量。合理设置线程数,通常等于CPU核心数或略高。

基本上就这些,不复杂但容易忽略细节。重点是锁的粒度和条件变量的正确使用。

相关专题

更多
javascriptvoid(o)怎么解决
javascriptvoid(o)怎么解决

javascriptvoid(o)的解决办法:1、检查语法错误;2、确保正确的执行环境;3、检查其他代码的冲突;4、使用事件委托;5、使用其他绑定方式;6、检查外部资源等等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

173

2023.11.23

java中void的含义
java中void的含义

本专题整合了Java中void的相关内容,阅读专题下面的文章了解更多详细内容。

92

2025.11.27

lambda表达式
lambda表达式

Lambda表达式是一种匿名函数的简洁表示方式,它可以在需要函数作为参数的地方使用,并提供了一种更简洁、更灵活的编码方式,其语法为“lambda 参数列表: 表达式”,参数列表是函数的参数,可以包含一个或多个参数,用逗号分隔,表达式是函数的执行体,用于定义函数的具体操作。本专题为大家提供lambda表达式相关的文章、下载、课程内容,供大家免费下载体验。

202

2023.09.15

python lambda函数
python lambda函数

本专题整合了python lambda函数用法详解,阅读专题下面的文章了解更多详细内容。

188

2025.11.08

线程和进程的区别
线程和进程的区别

线程和进程的区别:线程是进程的一部分,用于实现并发和并行操作,而线程共享进程的资源,通信更方便快捷,切换开销较小。本专题为大家提供线程和进程区别相关的各种文章、以及下载和课程。

472

2023.08.10

Python 多线程与异步编程实战
Python 多线程与异步编程实战

本专题系统讲解 Python 多线程与异步编程的核心概念与实战技巧,包括 threading 模块基础、线程同步机制、GIL 原理、asyncio 异步任务管理、协程与事件循环、任务调度与异常处理。通过实战示例,帮助学习者掌握 如何构建高性能、多任务并发的 Python 应用。

131

2025.12.24

function是什么
function是什么

function是函数的意思,是一段具有特定功能的可重复使用的代码块,是程序的基本组成单元之一,可以接受输入参数,执行特定的操作,并返回结果。本专题为大家提供function是什么的相关的文章、下载、课程内容,供大家免费下载体验。

471

2023.08.04

js函数function用法
js函数function用法

js函数function用法有:1、声明函数;2、调用函数;3、函数参数;4、函数返回值;5、匿名函数;6、函数作为参数;7、函数作用域;8、递归函数。本专题提供js函数function用法的相关文章内容,大家可以免费阅读。

158

2023.10.07

php源码安装教程大全
php源码安装教程大全

本专题整合了php源码安装教程,阅读专题下面的文章了解更多详细内容。

74

2025.12.31

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Go语言实战之 GraphQL
Go语言实战之 GraphQL

共10课时 | 0.8万人学习

php-src源码分析探索
php-src源码分析探索

共6课时 | 0.5万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号