爆款云主机2核4G限时秒杀,88元/年起!
查看详情

活动

天翼云最新优惠活动,涵盖免费试用,产品折扣等,助您降本增效!
热门活动
  • 618智算钜惠季 爆款云主机2核4G限时秒杀,88元/年起!
  • 免费体验DeepSeek,上天翼云息壤 NEW 新老用户均可免费体验2500万Tokens,限时两周
  • 云上钜惠 HOT 爆款云主机全场特惠,更有万元锦鲤券等你来领!
  • 算力套餐 HOT 让算力触手可及
  • 天翼云脑AOne NEW 连接、保护、办公,All-in-One!
  • 中小企业应用上云专场 产品组合下单即享折上9折起,助力企业快速上云
  • 息壤高校钜惠活动 NEW 天翼云息壤杯高校AI大赛,数款产品享受线上订购超值特惠
  • 天翼云电脑专场 HOT 移动办公新选择,爆款4核8G畅享1年3.5折起,快来抢购!
  • 天翼云奖励推广计划 加入成为云推官,推荐新用户注册下单得现金奖励
免费活动
  • 免费试用中心 HOT 多款云产品免费试用,快来开启云上之旅
  • 天翼云用户体验官 NEW 您的洞察,重塑科技边界

智算服务

打造统一的产品能力,实现算网调度、训练推理、技术架构、资源管理一体化智算服务
智算云(DeepSeek专区)
科研助手
  • 算力商城
  • 应用商城
  • 开发机
  • 并行计算
算力互联调度平台
  • 应用市场
  • 算力市场
  • 算力调度推荐
一站式智算服务平台
  • 模型广场
  • 体验中心
  • 服务接入
智算一体机
  • 智算一体机
大模型
  • DeepSeek-R1-昇腾版(671B)
  • DeepSeek-R1-英伟达版(671B)
  • DeepSeek-V3-昇腾版(671B)
  • DeepSeek-R1-Distill-Llama-70B
  • DeepSeek-R1-Distill-Qwen-32B
  • Qwen2-72B-Instruct
  • StableDiffusion-V2.1
  • TeleChat-12B

应用商城

天翼云精选行业优秀合作伙伴及千余款商品,提供一站式云上应用服务
进入甄选商城进入云市场创新解决方案
办公协同
  • WPS云文档
  • 安全邮箱
  • EMM手机管家
  • 智能商业平台
财务管理
  • 工资条
  • 税务风控云
企业应用
  • 翼信息化运维服务
  • 翼视频云归档解决方案
工业能源
  • 智慧工厂_生产流程管理解决方案
  • 智慧工地
建站工具
  • SSL证书
  • 新域名服务
网络工具
  • 翼云加速
灾备迁移
  • 云管家2.0
  • 翼备份
资源管理
  • 全栈混合云敏捷版(软件)
  • 全栈混合云敏捷版(一体机)
行业应用
  • 翼电子教室
  • 翼智慧显示一体化解决方案

合作伙伴

天翼云携手合作伙伴,共创云上生态,合作共赢
天翼云生态合作中心
  • 天翼云生态合作中心
天翼云渠道合作伙伴
  • 天翼云代理渠道合作伙伴
天翼云服务合作伙伴
  • 天翼云集成商交付能力认证
天翼云应用合作伙伴
  • 天翼云云市场合作伙伴
  • 天翼云甄选商城合作伙伴
天翼云技术合作伙伴
  • 天翼云OpenAPI中心
  • 天翼云EasyCoding平台
天翼云培训认证
  • 天翼云学堂
  • 天翼云市场商学院
天翼云合作计划
  • 云汇计划
天翼云东升计划
  • 适配中心
  • 东升计划
  • 适配互认证

开发者

开发者相关功能入口汇聚
技术社区
  • 专栏文章
  • 互动问答
  • 技术视频
资源与工具
  • OpenAPI中心
开放能力
  • EasyCoding敏捷开发平台
培训与认证
  • 天翼云学堂
  • 天翼云认证
魔乐社区
  • 魔乐社区

支持与服务

为您提供全方位支持与服务,全流程技术保障,助您轻松上云,安全无忧
文档与工具
  • 文档中心
  • 新手上云
  • 自助服务
  • OpenAPI中心
定价
  • 价格计算器
  • 定价策略
基础服务
  • 售前咨询
  • 在线支持
  • 在线支持
  • 工单服务
  • 建议与反馈
  • 用户体验官
  • 服务保障
  • 客户公告
  • 会员中心
增值服务
  • 红心服务
  • 首保服务
  • 客户支持计划
  • 专家技术服务
  • 备案管家

了解天翼云

天翼云秉承央企使命,致力于成为数字经济主力军,投身科技强国伟大事业,为用户提供安全、普惠云服务
品牌介绍
  • 关于天翼云
  • 智算云
  • 天翼云4.0
  • 新闻资讯
  • 天翼云APP
基础设施
  • 全球基础设施
  • 信任中心
最佳实践
  • 精选案例
  • 超级探访
  • 云杂志
  • 分析师和白皮书
  • 天翼云·创新直播间
市场活动
  • 2025智能云生态大会
  • 2024智算云生态大会
  • 2023云生态大会
  • 2022云生态大会
  • 天翼云中国行
天翼云
  • 活动
  • 智算服务
  • 产品
  • 解决方案
  • 应用商城
  • 合作伙伴
  • 开发者
  • 支持与服务
  • 了解天翼云
      • 文档
      • 控制中心
      • 备案
      • 管理中心

      使用C++11特性实现一个简单的线程池

      首页 知识中心 软件开发 文章详情页

      使用C++11特性实现一个简单的线程池

      2024-06-06 07:16:49 阅读次数:38

      c++,开发语言

      运用到的知识点:智能指针,单例模式,懒汉模式,多线程,右值引用,可调用对象,完美转发,可变列表。

      使用C++11特性实现一个简单的线程池

      代码如下(一些细节全在注释中): 

      #include <iostream>
      #include <memory>
      #include <thread>
      #include <mutex>
      #include <condition_variable>
      #include <queue>
      #include <vector>
      #include <string>
      #include <functional>
      
      // 线程池(管理线程)
      // 生成者往任务队列中加任务,线程池去管理这个线程数组,
      // 调用线程数组去任务队列中取任务去完成
      
      class Threadpool {
      public:
      	// 获取线程池实例的静态方法
      	// std::make_shared无法访问私有或受保护的构造函数,
      	// 需要使用std::shared_ptr的构造函数来创建一个指向新Threadpool对象的共享指针
      	// 由于析构函数是私有属性所以需要手动指定删除器
      	static std::shared_ptr<Threadpool> getInstance(int numThreads) {
      		static std::shared_ptr<Threadpool> instance(new Threadpool(numThreads), [](Threadpool* p) {
      			delete p;
      		});
      		return instance;
      	}
      
      	// 加任务
      	// 由于传的参数个数不确定所以使用模板
      	// 可变列表
      	// 在函数模板中右值引用就是万能引用
      	template<class F, class... Args>
      	void enqueue(F&& f, Args&&... args) {
      		// 把函数的参数和函数绑定在一起后再调用这个函数的时候就不需要传参了
      		// 使用完美转发保证了参数以其原始的值类别被传递,
      		// 允许你有效利用移动语义并避免不必要的拷贝
      		// 你是左值引用就转化为左值引用,你是右值引用就转化为右值引用
      		// 若不使用完美转发所有的参数都会作为左值传递,即使它们原本是右值
      		// 因为出现传递过程
      		std::function<void()> task =
      			std::bind(std::forward<F>(f), std::forward<Args>(args)...);
      		// 注意加锁的范围
      		{
      			std::unique_lock<std::mutex> loc(mtx);// 对共享变量一定不要忘记加锁
      			// 使用move函数是为了将对象的所有权转移给另一个对象,
      			// 避免不必要的拷贝和提高性能
      			tasks.emplace(std::move(task));
      		}
      
      		// 既然加任务了,所以要通知线程来取任务
      		condition.notify_one();
      	}
      
      private:
      	// 私有化构造函数,单例模式的需要
      	Threadpool(int numThreads) : stop(false) {
      		for (int i = 0; i < numThreads; ++i) {
      			// 不使用push_back的原因是会进行拷贝构造
      			// 根本的原因是thread不支持拷贝构造
      			threads.emplace_back([this] {
      				// 加循环的作用:
      				// 总结来说,while(1) 循环在这个线程池构造函数中的作用是:
      				// 让每个工作线程在其生命周期内持续地处理任务。
      				// 线程会在有任务可执行时被唤醒,
      				// 当没有任务且收到停止信号时退出循环,从而优雅地结束其执行。
      				// 这种设计使得线程池可以高效地管理和执行多个任务,
      				// 而不需要频繁地创建和销毁线程。
      				while (1) {
      					std::unique_lock<std::mutex> lock(mtx);
      					// 满足条件就继续执行,否则阻塞
      					condition.wait(lock, [this] {
      						// 任务队列不为空就不阻塞
      						// 线程终止就继续执行到线程终止的语句
      						return !tasks.empty() || stop;
      					});
      
      					if (stop && tasks.empty()) return;// 线程终止就结束函数
      
      					// 若到现在仍然可以执行到这里说明可以正常的取任务
      					// 可以使用auto自动推导类型
      					std::function<void()> task(std::move(tasks.front()));
      					tasks.pop();// 任务出队列
      					lock.unlock();// 已经取到任务了就让其他线程去取任务
      					task();// 调用该线程取到的任务
      				}
      			});
      		}
      	}
      
      	~Threadpool() {
      		{
      			//只要是多个线程访问的函数就需要加锁
      			std::unique_lock<std::mutex> lock(mtx);
      			stop = true;
      		}
      		// 现在stop为真,所以通知所有线程工作
      		// 将任务队列中的所有任务都取完
      		condition.notify_all();
      		// 使用join()的时候不能使用const关键字
      		// 因为join()本身就是一个修改操作
      		for (auto& t : threads) {
      			t.join();
      		}
      	}
      
      	// 禁止拷贝和赋值,单例模式的需要
      	Threadpool(const Threadpool&) = delete;
      	Threadpool& operator=(const Threadpool&) = delete;
      
      	std::vector<std::thread> threads;// 线程数组
      	std::queue<std::function<void()>> tasks;// 任务队列的参数当然是函数
      	std::mutex mtx;// 互斥锁
      	std::condition_variable condition;// 条件变量
      	bool stop;// 线程池什么时候终止
      };
      
      int main() {
      	// 使用单例模式获取线程池实例
      	std::shared_ptr<Threadpool> pool = Threadpool::getInstance(4);
      
      	// 加任务
      	for (int i = 0; i < 10; ++i) {
      		pool -> enqueue([i] {
      			std::cout << "task:" << i << " is running " << std::endl;
      			std::this_thread::sleep_for(std::chrono::seconds(1));
      			std::cout << "task:" << i << " is end " << std::endl;
      		});
      	}
      
      	// 主线程可以等待一些时间,否则主线程可能在任务完成前结束
      	std::this_thread::sleep_for(std::chrono::seconds(12));
      
      	return 0;
      }
      

      输出结果不唯一:

      task:0 is running
      task:3 is running
      task:2 is running
      task:1 is running
      task:3 is end
      task:2 is end
      task:5 is running
      task:0 is end
      task:1 is end
      task:7 is running
      task:6 is running
      task:4 is running
      task:4 is end
      task:5 is end
      task:9 is running
      task:6 is end
      task:7 is end
      task:8 is running
      task:9 is end
      task:8 is end
      版权声明:本文内容来自第三方投稿或授权转载,原文地址:https://blog.csdn.net/qq_73185160/article/details/135250391,作者:想不出来_6,版权归原作者所有。本网站转在其作品的目的在于传递更多信息,不拥有版权,亦不承担相应法律责任。如因作品内容、版权等问题需要同本网站联系,请发邮件至ctyunbbs@chinatelecom.cn沟通。

      上一篇:Python输出表格

      下一篇:二十四种场景全方位解读Python装饰器的用法

      相关文章

      2025-05-19 09:04:53

      查看RISC-V版本的gcc中默认定义的宏

      查看RISC-V版本的gcc中默认定义的宏

      2025-05-19 09:04:53
      c++ , linux
      2025-04-14 09:26:51

      【算法入门08】青蛙跳台阶

      【算法入门08】青蛙跳台阶

      2025-04-14 09:26:51
      c++ , 动态规划 , 算法
      2025-04-14 09:26:51

      STL详解(九)—— priority_queue的使用与模拟实现

      优先级队列默认使用vector作为其底层存储数据的容器,在vector上又使用了堆算法将vector中的元素构造成堆的结构,因此priority_queue就是堆,所有需要用到堆的位置,都可以考虑使用priority_queue。

      2025-04-14 09:26:51
      c++ , stl , 数据结构
      2025-04-14 09:26:51

      STL详解(八)—— stack和queue的模拟实现

      stack和queue有一点需要注意的是,虽然stack和queue中也可以存放元素,但在STL中并没有将其划分在容器的行列,而是将其称为容器适配器,这是因为stack和queue只是对其他容器的接口进行了包装,STL中stack和queue默认使用deque容器。

      2025-04-14 09:26:51
      c++ , queue , stack , stl
      2025-04-14 09:24:23

      【算法入门14】二叉树的镜像

      【算法入门14】二叉树的镜像

      2025-04-14 09:24:23
      c++ , 算法
      2025-04-14 09:24:23

      【算法入门09】矩形覆盖

      【算法入门09】矩形覆盖

      2025-04-14 09:24:23
      c++ , 动态规划 , 算法
      2025-04-07 10:28:48

      Python高维统计建模变量选择:SCAD平滑剪切绝对偏差惩罚、Lasso惩罚函数比较

      变量选择是高维统计建模的重要组成部分。许多流行的变量选择方法,例如 LASSO,都存在偏差。

      2025-04-07 10:28:48
      python , r语言 , 后端 , 开发语言
      2025-04-07 10:20:39

      ​Python是如何表示时间的?2个模块、3种方式,1文看懂~

      ​Python是如何表示时间的?2个模块、3种方式,1文看懂~

      2025-04-07 10:20:39
      python , 开发语言 , 时间戳 , 结构化
      2025-04-01 10:29:12

      golang与 C++数据结构类型对应关系是怎样的?

      uintptr和unsafe.Pointer相当于c++的void*,也就是任意指针。

      2025-04-01 10:29:12
      c++ , golang , 函数指针 , 数据结构
      2025-04-01 10:28:37

      找到非负数组中拥有“最大或的结果“的最短子数组,返回最短长度。

      找到非负数组中拥有"最大或的结果"的最短子数组,返回最短长度。

      2025-04-01 10:28:37
      java代码 , rust , 后端 , 开发语言 , 数组
      查看更多
      推荐标签

      作者介绍

      天翼云小翼
      天翼云用户

      文章

      33561

      阅读量

      5250261

      查看更多

      最新文章

      Python高维统计建模变量选择:SCAD平滑剪切绝对偏差惩罚、Lasso惩罚函数比较

      2025-04-07 10:28:48

      ​Python是如何表示时间的?2个模块、3种方式,1文看懂~

      2025-04-07 10:20:39

      golang与 C++数据结构类型对应关系是怎样的?

      2025-04-01 10:29:12

      找到非负数组中拥有“最大或的结果“的最短子数组,返回最短长度。

      2025-04-01 10:28:37

      【C语言】探索数据的存储(上篇)

      2025-04-01 09:21:49

      MFC编程 -- 判断是否按下ctrl和shift键

      2025-03-31 08:49:25

      查看更多

      热门文章

      Lambda函数

      2023-02-08 10:33:56

      QT中多线程的使用

      2023-02-07 10:34:04

      0030 简单的四则运算 c/c++

      2023-03-21 10:39:47

      C++虚函数知识点总结

      2023-02-21 06:21:46

      (10)Qt对象模型

      2023-02-13 07:55:59

      java学习第三天笔记-运算符10-短路逻辑运算符56

      2023-04-07 06:41:50

      查看更多

      热门标签

      java Java python 编程开发 代码 开发语言 算法 线程 Python html 数组 C++ 元素 javascript c++
      查看更多

      相关产品

      弹性云主机

      随时自助获取、弹性伸缩的云服务器资源

      天翼云电脑(公众版)

      便捷、安全、高效的云电脑服务

      对象存储

      高品质、低成本的云上存储服务

      云硬盘

      为云上计算资源提供持久性块存储

      查看更多

      随机文章

      网络通信第一课 C++封装HTTP请求报文说明

      使用加密算法时报错:ModuleNotFoundError: No module named ‘Crypto‘

      PAT_Advanced Level_1030 Travel Plan(C++_链式向前星_dfs_回溯)

      java实现连接远程服务器,并可以执行shell命令

      【java基础】条件判断,if、switch

      前端项目实战119-menu中 url改变侧边栏改变

      • 7*24小时售后
      • 无忧退款
      • 免费备案
      • 专家服务
      售前咨询热线
      400-810-9889转1
      关注天翼云
      • 旗舰店
      • 天翼云APP
      • 天翼云微信公众号
      服务与支持
      • 备案中心
      • 售前咨询
      • 智能客服
      • 自助服务
      • 工单管理
      • 客户公告
      • 涉诈举报
      账户管理
      • 管理中心
      • 订单管理
      • 余额管理
      • 发票管理
      • 充值汇款
      • 续费管理
      快速入口
      • 天翼云旗舰店
      • 文档中心
      • 最新活动
      • 免费试用
      • 信任中心
      • 天翼云学堂
      云网生态
      • 甄选商城
      • 渠道合作
      • 云市场合作
      了解天翼云
      • 关于天翼云
      • 天翼云APP
      • 服务案例
      • 新闻资讯
      • 联系我们
      热门产品
      • 云电脑
      • 弹性云主机
      • 云电脑政企版
      • 天翼云手机
      • 云数据库
      • 对象存储
      • 云硬盘
      • Web应用防火墙
      • 服务器安全卫士
      • CDN加速
      热门推荐
      • 云服务备份
      • 边缘安全加速平台
      • 全站加速
      • 安全加速
      • 云服务器
      • 云主机
      • 智能边缘云
      • 应用编排服务
      • 微服务引擎
      • 共享流量包
      更多推荐
      • web应用防火墙
      • 密钥管理
      • 等保咨询
      • 安全专区
      • 应用运维管理
      • 云日志服务
      • 文档数据库服务
      • 云搜索服务
      • 数据湖探索
      • 数据仓库服务
      友情链接
      • 中国电信集团
      • 189邮箱
      • 天翼企业云盘
      • 天翼云盘
      ©2025 天翼云科技有限公司版权所有 增值电信业务经营许可证A2.B1.B2-20090001
      公司地址:北京市东城区青龙胡同甲1号、3号2幢2层205-32室
      • 用户协议
      • 隐私政策
      • 个人信息保护
      • 法律声明
      备案 京公网安备11010802043424号 京ICP备 2021034386号