创建线程池和封装锁
封装一个锁
1.封装一个Mutex
class Mutex{public:Mutex(pthread_mutex_t * lock):_lock(lock){}void Lock(){pthread_mutex_lock(_lock);}void unLock(){pthread_mutex_unlock(_lock);}~Mutex(){}private:pthread_mutex_t *_lock;
};
2.封装一个LockGuard
class LockGuard{public:LockGuard(pthread_mutex_t * lock):_mutex(lock){_mutex.Lock();}~LockGuard(){_mutex.unLock();}private:Mutex _mutex;
};
在底层就可以直接创建一个LockGuard对象,就可以直接对临时资源进行加锁
类似:
{LockGuard(&mutex);//临界资源}
创建线程池
封装线程
1.成员变量
private:std::string _threadname;pthread_t _pid;func_t<T> _func;bool _isrunning;T _data;
template <class T>
using func_t = std::function<void(T&)>;
我们创建一个fun_t 用来传递一个函数给线程,在内部用来回调。
2.构造函数
Thread(std::string threadname, func_t<T> func, T& data): _threadname(threadname), _pid(0), _func(func), _isrunning(false), _data(data){}
3.Start函数和Join函数
bool Start(){int n = pthread_create(&_pid, nullptr, ThreadRoutine, this);if (n == 0){_isrunning = true;return true;}return false;}bool Join(){if(!_isrunning) return true;int n=pthread_join(_pid,nullptr);if(n==0){_isrunning=false;return true;}else{return false;}}
4.在创建线程传递一个ThreadRoution函数
static void *ThreadRoutine(void *args) // 类内方法,{// (void)args; // 仅仅是为了防止编译器有告警Thread *ts = static_cast<Thread *>(args);ts->_func(ts->_data);return nullptr;}
ThreadRountion可不可以为类内函数?
不可以,类内函数默认隐藏的传递this指针,我们必须设置为静态函数函数,再传递this指针。
#pragma once#include <iostream>
#include <pthread.h>
#include <functional>
#include <cstring>template <class T>
using func_t = std::function<void(T&)>;template <class T>
class Thread
{
public:Thread(std::string threadname, func_t<T> func, T& data): _threadname(threadname), _pid(0), _func(func), _isrunning(false), _data(data){}static void *ThreadRoutine(void *args) // 类内方法,{// (void)args; // 仅仅是为了防止编译器有告警Thread *ts = static_cast<Thread *>(args);ts->_func(ts->_data);return nullptr;}bool Start(){int n = pthread_create(&_pid, nullptr, ThreadRoutine, this);if (n == 0){_isrunning = true;return true;}return false;}bool Join(){if(!_isrunning) return true;int n=pthread_join(_pid,nullptr);if(n==0){_isrunning=false;return true;}else{return false;}}const std::string& Threadname(){return _threadname;} private:std::string _threadname;pthread_t _pid;func_t<T> _func;bool _isrunning;T _data;
};
创建线程池
我们打算用queue来储存任务,用vector数组储存线程
当任务队列为空时,我们用条件变量去控制线程睡眠,队列Push进任务再控制线程醒来。
1.成员变量
private:queue<T> _taskq;vector<Thread<ThreadData>> _ptdv;pthread_mutex_t _mutex;pthread_cond_t _cond;int _thread_num;
2.构造函数
初始化锁,条件变量,并创建线程。
pthread_pool(int thread_num = defaultthreadnum) : _thread_num(thread_num){pthread_mutex_init(&_mutex, nullptr);pthread_cond_init(&_cond, nullptr);for (int i = 1; i <= defaultthreadnum; i++){string threadname("thread-");threadname += to_string(i);ThreadData td(threadname);Thread<ThreadData> t(threadname,std::bind(&pthread_pool<T>::pthread_Run, this, std::placeholders::_1), td);_ptdv.push_back(t);lg.LogMessage(Info, "%s is created...\n", threadname.c_str());}}
任务队列为空,让所有线程休眠,队列中有任务,直接让线程执行任务:t()
void pthread_Run(ThreadData &data){while (true){T t;{LockGuard ld(&_mutex);if (_taskq.empty()){allthreadsleep(data);}t = _taskq.front();_taskq.pop();}t();{LockGuard ld(&_mutex);lg.LogMessage(Info, "Thread name:%s is handling: %s \n", data._name.c_str(), t.PrintTask().c_str());lg.LogMessage(Info, "Thread name:%s get result: %s \n", data._name.c_str(), t.PrintResult().c_str());}}}
3.进程唤醒与进程休眠
void allthreadwakeup(){pthread_cond_signal(&_cond);}
void allthreadsleep(const ThreadData &data){lg.LogMessage(Debug, "no task, %s is sleeping...\n", data._name.c_str());pthread_cond_wait(&_cond, &_mutex);}
4.Push()
void Push(T &task){{LockGuard ld(&_mutex);_taskq.push(task);// 插入任务后唤醒进程allthreadwakeup();}}
#pragma once
#include <iostream>
#include <vector>
#include <queue>
#include <pthread.h>
#include <cstring>
#include <functional>
#include <unistd.h>
#include "pthread.hpp"
#include "LockGuard.hpp"
#include "Log.hpp"
using namespace std;
static const int defaultthreadnum = 5;template <class T>
using func_r = std::function<void(T)>;class ThreadData
{
public:ThreadData(string name) : _name(name){}~ThreadData(){}public:string _name;
};
template <class T>
class pthread_pool
{
public:static pthread_pool<T> *Getinstance(){if (instance == nullptr){pthread_mutex_lock(&_sig_ins);if (instance == nullptr){instance = new pthread_pool<T>(defaultthreadnum);lg.LogMessage(Info, "instance is create succeess...\n");return instance;}}}pthread_pool(int thread_num = defaultthreadnum) : _thread_num(thread_num){pthread_mutex_init(&_mutex, nullptr);pthread_cond_init(&_cond, nullptr);for (int i = 1; i <= defaultthreadnum; i++){string threadname("thread-");threadname += to_string(i);ThreadData td(threadname);Thread<ThreadData> t(threadname,std::bind(&pthread_pool<T>::pthread_Run, this, std::placeholders::_1), td);_ptdv.push_back(t);lg.LogMessage(Info, "%s is created...\n", threadname.c_str());}}pthread_pool(const pthread_pool<T> &pp) = delete;const pthread_pool<T> &operator=(const pthread_pool<T> &pp) = delete;void allthreadwakeup(){pthread_cond_signal(&_cond);}void allthreadsleep(const ThreadData &data){lg.LogMessage(Debug, "no task, %s is sleeping...\n", data._name.c_str());pthread_cond_wait(&_cond, &_mutex);}void pthread_Run(ThreadData &data){while (true){T t;{LockGuard ld(&_mutex);if (_taskq.empty()){allthreadsleep(data);}t = _taskq.front();_taskq.pop();}t();{LockGuard ld(&_mutex);lg.LogMessage(Info, "Thread name:%s is handling: %s \n", data._name.c_str(), t.PrintTask().c_str());lg.LogMessage(Info, "Thread name:%s get result: %s \n", data._name.c_str(), t.PrintResult().c_str());}}}void Start(){for (auto &th : _ptdv){th.Start();lg.LogMessage(Info, "%s is running ...\n", th.Threadname().c_str());}}void Push(T &task){{LockGuard ld(&_mutex);_taskq.push(task);// 插入任务后唤醒进程allthreadwakeup();}}// Just for debug success!void Wait(){for (auto &th : _ptdv){th.Join();}}~pthread_pool(){pthread_mutex_destroy(&_mutex);pthread_cond_destroy(&_cond);}private:queue<T> _taskq;vector<Thread<ThreadData>> _ptdv;pthread_mutex_t _mutex;pthread_cond_t _cond;int _thread_num;static pthread_pool *instance;static pthread_mutex_t _sig_ins;
};
template <class T>
pthread_pool<T> *pthread_pool<T>::instance = nullptr;
template <class T>
pthread_mutex_t pthread_pool<T>::_sig_ins = PTHREAD_MUTEX_INITIALIZER;
线程池单利化问题
static pthread_pool<T> *Getinstance(){if (instance == nullptr){pthread_mutex_lock(&_sig_ins);if (instance == nullptr){instance = new pthread_pool<T>(defaultthreadnum);lg.LogMessage(Info, "instance is create succeess...\n");return instance;}}}
在获取单例的函数中,我们是需要加锁的,防止多个线程同时进入创建出多个单利。
相关文章:
创建线程池和封装锁
封装一个锁 1.封装一个Mutex class Mutex{public:Mutex(pthread_mutex_t * lock):_lock(lock){}void Lock(){pthread_mutex_lock(_lock);}void unLock(){pthread_mutex_unlock(_lock);}~Mutex(){}private:pthread_mutex_t *_lock; };2.封装一个LockGuard class LockGuard{pub…...

易图讯军用VR三维电子沙盘系统
深圳易图讯军用VR三维电子沙盘系统是一种集成了虚拟现实(VR)技术、三维建模技术、大数据分析、实时动态更新以及高度安全可靠的综合性军事指挥平台。该系统通过高精度三维模型真实再现战场环境,为指挥员提供沉浸式体验和交互操作的可能性&…...

LeetCode讲解篇之70. 爬楼梯
文章目录 题目描述题解思路题解代码题目链接 题目描述 题解思路 爬楼梯有一个规律,爬到第n层楼梯的方法种数 爬到第n - 1层楼梯的方法种数 爬到第n - 1层楼梯的方法种数 也就是我们爬到第n层楼梯其实是从第n - 1层楼梯向上爬1层或者是n - 2层楼梯向上爬2层转换来…...

论文写作不再难,论文初稿快速成型法!
撰写论文是每个学者的必修课,我非常明白撰写论文的不易。撰写过程中会遇到各种困扰,如思路不清晰、论证不充分、语言表达不准确等。在这里以我的经验分享给大家一个能快速完成论文初稿的秘诀“AI导师写作”,希望能帮助还在为论文发愁的你。 …...
linux系统,监控进程运行状态并自动重启崩溃后的进程的多种方法
系统进程运行异常崩溃后,自动重启的方法 有的公司,会写monitor守护进程,监视各个进程的运行状态,异常时,自动重启,但是这种,通过一个进程 监护一个进程的做法,不太完美,…...

【JavaEE初阶】深入理解不同锁的意义,synchronized的加锁过程理解以及CAS的原子性实现(面试经典题);
前言 🌟🌟本期讲解关于锁的相关知识了解,这里涉及到高频面试题哦~~~ 🌈上期博客在这里:【JavaEE初阶】深入理解线程池的概念以及Java标准库提供的方法参数分析-CSDN博客 🌈感兴趣的小伙伴看一看小编主页&am…...

详解Redis分布式锁在SpringBoot的@Async方法中没锁住的坑
背景 Redis分布式锁很有用处,在秒杀、抢购、订单、限流特别是一些用到异步分布式并行处理任务时频繁的用到,可以说它是一个BS架构的应用中最高频使用的技术之一。 但是我们经常会碰到这样的一个问题,那就是我们都按照标准做了但有时运行着、…...

怎么做接口自动化测试
在分层测试的“金字塔”模型中,接口测试属于第二层服务集成测试范畴。相比UI层(主要是WEB或APP)自动化测试而言,接口自动化测试收益更大,且容易实现,维护成本低,有着更高的投入产出比࿰…...

网络编程(18)——使用asio协程实现并发服务器
十八、day18 到目前为止,我们以及学习了单线程同步/异步服务器、多线程IOServicePool和多线程IOThreadPool模型,今天学习如何通过asio协程实现并发服务器。 并发服务器有以下几种好处: 协程比线程更轻量,创建和销毁协程的开销较…...

Koa2项目实战2(路由管理、项目结构优化)
添加路由(处理不同的URL请求) 路由:根据不同的URL,调用对应的处理函数。 每一个接口服务,最核心的功能是:根据不同的URL请求,返回不同的数据。也就是调用不同的接口返回不同的数据。 在 Node…...

决战Linux操作系统
前言: 你是否也曾经为Linux所困扰过,在网上找的资料零零散散,是否学完Linux后还是懵懵懂懂,别怕,这篇博客是博主精心为你准备的,现在,就让我们一起来走进Linux的世界,决战Linux&…...
OceanBase 3.2.2 数据库问题处理记录
只记录OceanBase 数据库与OCP的异常处理,其它组件暂时不写录。 一、问题1: 说明:OMS 出现异常,无法访问(OB无法访问) OB数据库架构:1:1:1 原因:某一台OBserver因为内存问题,被服务器直接kill掉…...

HCIP--以太网交换安全(二)端口安全
端口安全 一、端口安全概述 1.1、端口安全概述:端口安全是一种网络设备防护措施,通过将接口学习的MAC地址设为安全地址防止非法用户通信。 1.2、端口安全原理: 类型 定义 特点 安全动态MAC地址 使能端口而未是能Stichy MAC功能是转换的…...

在 Windows 11 安卓子系统中安装 APK 的操作指南
这个软件好像不可以在纯android系统中使用(不知道是缺了什么),其他对于android的虚拟机要不缺少必要功能组件,要不性能过于低下。本方法致力于在带有谷歌框架WSA中运行该APK 在 Windows 11 安卓子系统中安装 APK 的操作指南 本指…...

[C语言] 函数详解:库函数与自定义函数
文章目录 函数的概念库函数和自定义函数库函数使用库函数示例常用库函数及头文件 自定义函数自定义函数的基本结构示例:实现两个数的求和函数自定义函数的好处 函数的返回值有返回值的函数无返回值的函数 函数的声明与调用声明函数在另一个文件中调用函数示例&#…...
0x11 科迈 RAS系统 Cookie验证越权漏洞
参考: 科迈 RAS系统 Cookie验证越权漏洞 | PeiQi文库 (wgpsec.org)免责声明 欢迎访问我的博客。以下内容仅供教育和信息用途: 合法性:我不支持或鼓励非法活动。请确保遵守法律法规。信息准确性:尽管我尽力提供准确的信息,但不保证其完全准确或适用。使用前请自行验证。风…...

MoonBit 双周报 Vol.57:AI助手功能增强、表达式优先级调整、JS 交互优化、标准库与实验库API多项更新!
2024-10-08 IDE更新 AI Codelens支持 /generate 和 /fix 命令 /generate 命令能够提供一个通用的用以生成代码的聊天界面。 /fix 命令能够读取当前函数的错误信息给出修复建议。 MoonBit更新 调整中缀表达式和if、match、loop、while、for、try表达式的优先级, 后者这些控制…...
element ui input textarea控制显示高度
样式代码 .testPage { position: absolute; left: 0; top: 0; right: 0; bottom: 0; display: flex; height: 100%; /* 控制输入框高度 */ .el-textarea { height: 90%; ::v-deep .el-textarea__inner { height: 90%; } } }...
Chromium 中chrome.downloads扩展接口c++
一、前端chrome.downloads 使用 chrome.downloads API 以编程方式启动、监控、操作和搜索下载内容。 权限 downloads 您必须在扩展程序清单中声明 "downloads" 权限,才能使用此 API。 {"name": "My extension",..."permiss…...
微信小程序常见问题
一、编译报错 [ app.json 文件内容错误] app.json: 在项目根目录未找到 app.json 解决办法: 微信开发者工具中打开设置->安全设置->打开服务端口用HBuilder X打开小程序文件夹,点击“运行到小程序模拟器”,生成配置文件,…...

深入剖析AI大模型:大模型时代的 Prompt 工程全解析
今天聊的内容,我认为是AI开发里面非常重要的内容。它在AI开发里无处不在,当你对 AI 助手说 "用李白的风格写一首关于人工智能的诗",或者让翻译模型 "将这段合同翻译成商务日语" 时,输入的这句话就是 Prompt。…...

docker详细操作--未完待续
docker介绍 docker官网: Docker:加速容器应用程序开发 harbor官网:Harbor - Harbor 中文 使用docker加速器: Docker镜像极速下载服务 - 毫秒镜像 是什么 Docker 是一种开源的容器化平台,用于将应用程序及其依赖项(如库、运行时环…...
第25节 Node.js 断言测试
Node.js的assert模块主要用于编写程序的单元测试时使用,通过断言可以提早发现和排查出错误。 稳定性: 5 - 锁定 这个模块可用于应用的单元测试,通过 require(assert) 可以使用这个模块。 assert.fail(actual, expected, message, operator) 使用参数…...

论文浅尝 | 基于判别指令微调生成式大语言模型的知识图谱补全方法(ISWC2024)
笔记整理:刘治强,浙江大学硕士生,研究方向为知识图谱表示学习,大语言模型 论文链接:http://arxiv.org/abs/2407.16127 发表会议:ISWC 2024 1. 动机 传统的知识图谱补全(KGC)模型通过…...

用docker来安装部署freeswitch记录
今天刚才测试一个callcenter的项目,所以尝试安装freeswitch 1、使用轩辕镜像 - 中国开发者首选的专业 Docker 镜像加速服务平台 编辑下面/etc/docker/daemon.json文件为 {"registry-mirrors": ["https://docker.xuanyuan.me"] }同时可以进入轩…...

AI+无人机如何守护濒危物种?YOLOv8实现95%精准识别
【导读】 野生动物监测在理解和保护生态系统中发挥着至关重要的作用。然而,传统的野生动物观察方法往往耗时耗力、成本高昂且范围有限。无人机的出现为野生动物监测提供了有前景的替代方案,能够实现大范围覆盖并远程采集数据。尽管具备这些优势…...

Razor编程中@Html的方法使用大全
文章目录 1. 基础HTML辅助方法1.1 Html.ActionLink()1.2 Html.RouteLink()1.3 Html.Display() / Html.DisplayFor()1.4 Html.Editor() / Html.EditorFor()1.5 Html.Label() / Html.LabelFor()1.6 Html.TextBox() / Html.TextBoxFor() 2. 表单相关辅助方法2.1 Html.BeginForm() …...

(一)单例模式
一、前言 单例模式属于六大创建型模式,即在软件设计过程中,主要关注创建对象的结果,并不关心创建对象的过程及细节。创建型设计模式将类对象的实例化过程进行抽象化接口设计,从而隐藏了类对象的实例是如何被创建的,封装了软件系统使用的具体对象类型。 六大创建型模式包括…...
上位机开发过程中的设计模式体会(1):工厂方法模式、单例模式和生成器模式
简介 在我的 QT/C 开发工作中,合理运用设计模式极大地提高了代码的可维护性和可扩展性。本文将分享我在实际项目中应用的三种创造型模式:工厂方法模式、单例模式和生成器模式。 1. 工厂模式 (Factory Pattern) 应用场景 在我的 QT 项目中曾经有一个需…...

云安全与网络安全:核心区别与协同作用解析
在数字化转型的浪潮中,云安全与网络安全作为信息安全的两大支柱,常被混淆但本质不同。本文将从概念、责任分工、技术手段、威胁类型等维度深入解析两者的差异,并探讨它们的协同作用。 一、核心区别 定义与范围 网络安全:聚焦于保…...