C++ 封装线程池(结合QT支持信号机制)

纯C++风格线程池

纯C++ 风格线程池可参考这篇文章

https://llfc.club/category?catid=225RaiVNI8pFDD5L4m807g7ZwmF#!aid/2c2IJUcCUOfzEQQRRdOXYIZuCjP

视频教程

相关线程池和并发编程的视频可以看看这个连接:

https://www.bilibili.com/video/BV1Xt421H7M7/?vd_source=8be9e83424c2ed2c9b2a3ed1d01385e9

支持信号机制的线程池

我的项目中期待封装一个类,内部有个线程池处理外部投递的内容,这个类同时支持对外发送信号等,同时这个类是一个单例类,那么这个类可以继承QOjbject支持信号机制,并且其内部可以封装一个线程池响应外部投递的任务,结合纯C++版本封装了如下在QT环境使用的线程池,目前已经投入到生产中。

用到的头文件

#include <QObject>
#include <queue>
#include <vector>
#include <thread>
#include <queue>
#include <memory>
#include <functional>
#include <mutex>
#include <atomic>
#include <future>

头文件编写

#ifndef SEQSCHEDULER_H
#define SEQSCHEDULER_H
//wwc 处理维护,关机流程,清洗等时序执行的类
class SeqScheduler: public QObject
{Q_OBJECT
public:~ SeqScheduler();static SeqScheduler& Inst();template<typename F, typename ... Args>auto CommitTask(F&& func, Args && ... args) ->std::future<decltype(std::forward<F>(func)(std::forward<Args>(args)...))> {using RetType = decltype(std::forward<F>(func)(std::forward<Args>(args)...));if (_b_stop.load()) {return std::future<RetType>{};}auto bind_func = std::bind(std::forward<F>(func), std::forward<Args>(args)...);auto pack_task = std::make_shared<std::packaged_task<RetType(void)>>(bind_func);auto future = pack_task->get_future();{std::lock_guard<std::mutex> lock(_work_mtx);_work_que.push([pack_task]() {(*pack_task)();});}_work_con.notify_one();return future;}private: SeqScheduler(const SeqScheduler&) = delete;SeqScheduler& operator = (const SeqScheduler&) = delete;SeqScheduler(unsigned int num = std::thread::hardware_concurrency());std::queue<std::function<void(void)>> _work_que;std::mutex _work_mtx;std::condition_variable _work_con;std::atomic<bool>  _b_stop;std::vector<std::thread> _pool;std::atomic_int          _thread_num;
};#endif // SEQSCHEDULER_H

类的具体实现

#include "seqscheduler.h"SeqScheduler::SeqScheduler(unsigned int num ): _b_stop(false)
{if (num <= 1)_thread_num = 1;else_thread_num = num;for (int i = 0; i < _thread_num; i++) {_pool.emplace_back([this]() {for (; !(_b_stop.load());) {std::unique_lock<std::mutex> unique_locker(_work_mtx);_work_con.wait(unique_locker, [this]() {if (_b_stop.load()) {return true;}if (_work_que.empty()) {return false;}return true;});if (_b_stop.load()) {return;}//出队auto task = _work_que.front();_work_que.pop();unique_locker.unlock();task();}});}}SeqScheduler& SeqScheduler::Inst()
{static SeqScheduler inst;return inst;
}SeqScheduler::~SeqScheduler(){_b_stop = true;{std::unique_lock<std::mutex> unique_locker(_work_mtx);_work_con.notify_all();}for (auto& td : _pool) {if (td.joinable()) {std::cout << "join thread " << td.get_id() << std::endl;td.join();}}
}

使用线程池

线程池的使用可以通过如下方式投递任务,任务在后台自动执行

void Test(){SeqScheduler::Inst().CommitTask([]() {asyncLog("slot machine perfusion called ");});
}

如需等待任务完成,可以用wait或者get

void Test(){auto task_future = SeqScheduler::Inst().CommitTask([]() {asyncLog("slot machine perfusion called ");});task_future.wait();
}

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/pingmian/19233.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

【C language】判断一个正整数是否是2^n

题解&#xff1a;判断一个正整数是否是2^n(位运算方法) 1.题目 判断一个正整数是否是2^n 2.位运算法 思路&#xff1a;干掉二进制最右边的1&#xff0c;看是否是0 int main() {int num 16;if ((num & (num - 1)) 0) printf("the num is a 2^n");else print…

Ubuntu 修改镜像源为阿里云【详细步骤】

文章目录 修改步骤第 1 步:安装 vim 软件第 2 步:备份源第 3 步:修改为阿里云镜像附录 - 其它版本配置ubuntu 14.04 LTS (trusty) (EOL)ubuntu 16.04 LTS (xenial) (EOL)ubuntu 18.04 LTS (bionic)ubuntu 20.04 LTS (focal)ubuntu 22.04 LTS (jammy)ubuntu 23.04 (lunar)ubu…

基于51单片机的交通灯设计

一.硬件方案 本设计能模拟基本的交通控制系统&#xff0c;用红绿黄灯表示禁行&#xff0c;通行和等待的信号发生&#xff0c;还能进行倒计时显示。按键可以控制禁行、深夜模式、复位、东西通行、南北通行、时间加、时间减、切换等功能。共四个二位阴极数码管&#xff0c;东南西…

polarctf靶场[reverse]shell、PE结构、拼接

[reverse]shell 考点&#xff1a;脱壳 将所解压的文件拖入DIE有无有壳&#xff0c;文件类型 发现有UPX壳&#xff0c;是32位的文件&#xff0c;先脱壳 用FFI工具脱壳 将脱壳后的程序用32位IDA进行反汇编 点开_main_0函数进行查看 看到flag&#xff0c;&#xff08;F5&#…

小红书广告如何推广?投放费用是多少?

小红书以其独特的社区文化和用户粘性&#xff0c;成为了众多品牌争相推广的热门平台&#xff0c;如何在小红书上有效推广广告&#xff0c;让品牌信息精准触达目标用户&#xff0c;成为了众多营销人员关注的焦点&#xff0c;云衔科技为企业提供专业的开户和代运营服务。 一、小…

TOGAF企业架构章节(核心)知识点(一)

TOGAF标准9.2一共有 6 部分&#xff1a; 第一部分&#xff08;简介&#xff09;&#xff1a;企业架构的关键概念&#xff0c;特别是 TOGAF 方法进行了概要介绍第二部分&#xff08;架构开发方法&#xff09;&#xff1a; TOGAF 框架的核心部分。描述了 TOGAF 架构开发方法&…

爪哇,我初学乍道

>>上一篇&#xff08;学校上课&#xff0c;是耽误我学习了。。&#xff09; 2016年9月&#xff0c;我大二了。 自从我发现上课会耽误我学习&#xff0c;只要我认为不影响我期末学分的&#xff0c;我就逃课了。 绝大多数课都是要签到的&#xff0c;有的是老师突击喊名字…

C/C++运行时库与 UCRT 通用运行时库:全面总结与问题实例剖析

推荐一个AI网站&#xff0c;免费使用豆包AI模型&#xff0c;快去白嫖&#x1f449;海鲸AI 1. 概述 在开发C/C应用程序时&#xff0c;运行时库&#xff08;Runtime Library&#xff09;是不可或缺的一部分。它们提供了一系列函数和功能&#xff0c;使得开发者能够更方便地进行编…

【Docker】2、配置SSL证书远程访问Docker

1、使用 openssl 生成 ca 1、创建文件夹 mkdir -p /root/dockercd /root/docker2、创建 RSA 私钥 会提示 2 次输入证书密码&#xff0c;至少 4 位&#xff0c;创建后会生成一个 ca-key.pem 文件 openssl genrsa -aes256 -out ca-key.pem 4096得到 ca-key.pem 文件 3、创建…

海外仓跨境系统:性价比之选,助力中小仓库事业腾飞

海外仓作为跨境电商的重要基础设施&#xff0c;对于提升跨境电商效率起到了至关重要的作用。尤其是对一些小型海外仓来说&#xff0c;如何高效稳定的运维&#xff0c;选择一款合适的海外仓跨境系统就变得非常关键。 今天我们就从性价比&#xff0c;功能性两个方面出发&#xf…

2024-05-29 架构-程序设计-思考

摘要: 最近在抽出时间做一个数据库的driver, 其中有些问题驱动的软件代码的思考&#xff0c;是很值得回味的。 做的系统&#xff0c;所思考的问题&#xff0c;所设计的解决方案&#xff0c;其实都是可以看作是对解决问题方式。而不仅仅是某个类库的API的使用&#xff0c;某个…

倩女幽魂手游攻略:新人入坑必看指南!

《倩女幽魂》是一款经典的MMORPG游戏&#xff0c;凭借其丰富的剧情、精美的画面和多样的玩法&#xff0c;吸引了众多玩家。在游戏中&#xff0c;提升角色等级和战斗力是每个玩家的核心目标。本文将详细介绍如何在游戏中快速提升角色等级、增强实力&#xff0c;并提供一些实用的…

Java break细节(标签)

Java break细节(标签)continue也可以使用标签 break是用来跳出循环的。 当有多重循环时&#xff0c;可以配合标签来使用&#xff0c;决定跳出那一重循环。 尽量不要使用标签 1、不代标签时&#xff0c;默认跳出 break 所在的那重循环&#xff1a; 可见在 i 3 时&#xff0…

数据集——高分辨率图像分割成大小均匀图像(附Python代码)

将高分辨率图像分割成大小均匀的图像用于训练&#xff0c;可以提高训练效率&#xff0c;提高模型性能&#xff0c;并提供更大的灵活性。 目录 一、大小均匀图像用于训练优势二、代码2.1 代码参数修改2.2 代码2.3 输出2.4 分割结果 三、总结 一、大小均匀图像用于训练优势 内存…

onenav一为导航主题4.05开心版 可保存授权

一款大多数导航网站使用且功能非常全面的导航主题&#xff0c;有能力的情况下还是劝大家支持正版。 演示站&#xff1a;onenav一为导航主题演示站 后台演示 | 演示后台&#xff1a;登录 - onenav一为导航主题演示站 后台演示 后台测试账号获取&#xff1a;演示站后台账号获取…

快团团供货大团长如何打印电子面单?

一、功能说明 快团团打单平台是目前唯一一个服务于快团团团长的打单发货工具&#xff0c;免费提供给团长使用。可帮助团长快速打印面单、分拣包裹、完成发货。 目前快团团打单平台已支持大批量打印快递单、自定义快递面单、自动发货、绑定拼多多电子面单账号等功能&#xff0c…

重学java51.Collections集合工具类、泛型

"我已不在地坛&#xff0c;地坛在我" —— 《想念地坛》 24.5.28 一、Collections集合工具类 1.概述:集合工具类 2.特点: a.构造私有 b.方法都是静态的 3.使用:类名直接调用 4.方法: static <T> boolean addAll(collection<? super T>c,T... el…

AVL树的模拟实现

我们上期提到了二叉搜索树&#xff0c;只是简单的讲了一下原理&#xff0c;那么今天我们就讲一下AVL树。 目录 AVL树的概念AVL树的实现AVL树的架构insert插入引用pair对象引进parent指针仅插入数据调节平衡因子情况1&#xff1a;插入在父亲的右边&#xff0c;父亲的平衡因子后…

单元测试Mock中常见问题与解决方案

很久不写博客了&#xff0c;经常搜索前辈和晚辈写的问题解决方案&#xff0c;得到很多帮助&#xff0c;也受益匪浅&#xff0c;所以也时常感到愧疚。那么接下来一段时间&#xff0c;我也分享一些技术点&#xff0c;问题方案吧。闻道有先后&#xff0c;术业有专攻。也希望我们都…

数据库到服务器提权

数据库提权流程&#xff1a; 1、先获取到数据库用户密码 -网站存在SQL注入漏洞 -数据库的存储文件或备份文件 -网站应用源码中的数据库配置文件 -采用工具或脚本爆破(需解决外联问题) 2、利用数据库提权项目进行连接 MDUT //jkd1.8 启动 Databasetools …