0

0

C++怎么实现一个线程池_C++并发编程与线程池实现

冰火之心

冰火之心

发布时间:2025-11-09 08:07:02

|

958人浏览过

|

来源于php中文网

原创

线程池通过复用线程执行任务以减少开销,核心包括线程集合、任务队列、互斥锁、条件变量和控制标志;submit方法提交任务并返回future获取结果,析构时安全关闭确保任务完成。

c++怎么实现一个线程池_c++并发编程与线程池实现

实现一个线程池的核心目标是:复用一组线程来执行多个任务,避免频繁创建和销毁线程带来的开销。在C++中,可以借助std::threadstd::queuestd::mutexstd::condition_variablestd::function工具完成一个高效且线程安全的线程池。

线程池的基本结构

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

  • 工作线程集合:固定数量的线程,在初始化时启动,等待任务。
  • 任务队列:存放待执行的任务(通常为std::function类型)。
  • 互斥锁(mutex):保护任务队列的线程安全访问。
  • 条件变量(condition_variable):用于通知空闲线程有新任务到来。
  • 控制标志:标识线程池是否关闭,是否等待任务完成。

任务提交与执行机制

用户通过submit方法提交可调用对象(如lambda、函数指针、bind表达式),线程池将其包装为std::function放入队列。工作线程循环等待任务,一旦获取到任务就立即执行。

使用std::packaged_task可以方便地获取任务的返回值,通过std::future机制实现异步结果获取。

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

示例代码片段:

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

线程池的生命周期管理

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

iWebMall多用户商城系统
iWebMall多用户商城系统

iWebMall 是一款高性能高扩展能力的开源 LAMP 电子商务软件,定位为大中型电子商务平台软件,服务于有建立电子商务需求的商业客户。这些商业客户不必学习任何计算机编程代码知识,只需要使用 iWebMall 软件他们就可以轻松建立一个功能强大的网上商城,实现用户注册、产品展示、在线定购、在线支付等电子商务功能;iWebMall 集成了产品发布与查询、会员注册登录、购物车、在线订单、在线支付、在

下载

析构函数需要妥善处理未完成的任务:

  • 设置stop标志位,防止新任务提交。
  • 唤醒所有等待中的线程。
  • 调用每个线程的join(),确保它们正常退出。

这样可以保证已提交的任务被执行完毕,避免资源泄漏或程序崩溃。

实际使用示例

以下是一个简单的使用场景:

ThreadPool pool(4); // 创建4个线程的线程池

std::vector> results; for (int i = 0; i < 8; ++i) { results.emplace_back( pool.submit([i] { std::this_thread::sleep_for(std::chrono::seconds(1)); return i * i; }) ); }

for (auto& result : results) { std::cout << result.get() << ' '; } // 输出: 0 1 4 9 16 25 36 49

这段代码提交了8个计算任务,由4个线程并发执行,最后收集结果。

基本上就这些。一个简洁高效的C++线程池不需要复杂设计,关键是正确处理并发同步和资源释放。

相关专题

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

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

172

2023.11.23

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

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

92

2025.11.27

lambda表达式
lambda表达式

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

200

2023.09.15

python lambda函数
python lambda函数

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

187

2025.11.08

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

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

463

2023.08.10

Java 并发编程高级实践
Java 并发编程高级实践

本专题深入讲解 Java 在高并发开发中的核心技术,涵盖线程模型、Thread 与 Runnable、Lock 与 synchronized、原子类、并发容器、线程池(Executor 框架)、阻塞队列、并发工具类(CountDownLatch、Semaphore)、以及高并发系统设计中的关键策略。通过实战案例帮助学习者全面掌握构建高性能并发应用的工程能力。

53

2025.12.01

function是什么
function是什么

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

468

2023.08.04

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

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

158

2023.10.07

虚拟号码教程汇总
虚拟号码教程汇总

本专题整合了虚拟号码接收验证码相关教程,阅读下面的文章了解更多详细操作。

25

2025.12.25

热门下载

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

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
最新Python教程 从入门到精通
最新Python教程 从入门到精通

共4课时 | 0.6万人学习

Rust 教程
Rust 教程

共28课时 | 3.8万人学习

Django 教程
Django 教程

共28课时 | 2.5万人学习

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

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