【Linux】线程池实现

📗线程池实现(单例模式)

  • 1️⃣线程池概念
  • 2️⃣线程池代码样例
  • 3️⃣部分问题与细节
    • 🔸类成员函数参数列表中隐含的this指针
    • 🔸单例模式
    • 🔸一个失误导致的bug
  • 4️⃣调用线程池完成任务

1️⃣线程池概念

线程池是一种线程使用模式。线程过多会带来调度开销,进而影响缓存局部性和整体性能。而线程池维护着多个线程,等待着监督管理者分配可并发执行的任务。这避免了在处理短时间任务时创建与销毁线程的代价。线程池不仅能够保证内核的充分利用,还能防止过分调度。可用线程数量应该取决于可用的并发处理器、处理器内核、内存、网络sockets等的数量。
线程池的应用场景:

  1. 需要大量的线程来完成任务,且完成任务的时间比较短。 WEB服务器完成网页请求这样的任务,使用线程池技术是非常合适的。因为单个任务小,而任务数量巨大,你可以想象一个热门网站的点击次数。 但对于长时间的任务,比如一个Telnet连接请求,线程池的优点就不明显了。因为Telnet会话时间比线程的创建时间大多了。
  2. 对性能要求苛刻的应用,比如要求服务器迅速响应客户请求。
  3. 接受突发性的大量请求,但不至于使服务器因此产生大量线程的应用。突发性大量客户请求,在没有线程池情况下,将产生大量线程,虽然理论上大部分操作系统线程数目最大值不是问题,短时间内产生大量线程可能使内存到达极限,出现错误.

线程池示例:

  1. 创建固定数量线程池,循环从任务队列中获取任务对象,
  2. 获取到任务对象后,执行任务对象中的任务接口

2️⃣线程池代码样例

以下为线程池代码:

#pragma once#include <iostream>
#include <queue>
#include <pthread.h>
#include <ctime>template<class T>
class ThreadPool
{private:std::queue<T> _q;//任务队列pthread_mutex_t _lock;pthread_cond_t _cond;//有任务时提醒线程执行任务static ThreadPool<T>* _instance;ThreadPool(){}   public:static ThreadPool<T>* getInstance()//单例模式,饿汉模式,静态成员{static pthread_mutex_t mtx = PTHREAD_MUTEX_INITIALIZER;if(nullptr == _instance)//双if提高效率,因为只有第一次获取_instance时才会实例化,后续无需再加锁实例化_instance{pthread_mutex_lock(&mtx);if(nullptr == _instance){_instance = new ThreadPool<T>();}pthread_mutex_unlock(&mtx);}return _instance;}void MutexInit(){pthread_mutex_init(&_lock, nullptr);}void MutexLock(){pthread_mutex_lock(&_lock);}void MutexUnLock(){pthread_mutex_unlock(&_lock);}bool IsEmpty(){return _q.size() == 0 ? true : false;}void ThreadWait(){pthread_cond_wait(&_cond, &_lock);}void ThreadWakeUp(){pthread_cond_signal(&_cond);}void PopTask(T* out)//取任务{//此处不应加锁,应为取任务的时候是带着锁的,若此时申请锁,会出现死锁现象*out = _q.front();_q.pop();}//类内部的成员方法都有隐含的this参数,因此要加上static修饰static void* Routine(void* args){ThreadPool<T>* tp = (ThreadPool<T>*) args;//接收this指针pthread_detach(pthread_self());//线程分离while(true){tp->MutexLock();//加锁,访问临界区_qwhile(tp->IsEmpty())//任务队列为空,挂起等待{tp->ThreadWait();}//到此处说明有任务T t;tp->PopTask(&t);tp->MutexUnLock();//退出临界区_qt();}return nullptr;}void ThreadPoolInit(int num)//初始化线程池{pthread_t p[num];for(int i = 0; i < num; i++){pthread_create(p + i, nullptr, Routine, this);//将this指针作为参数传入}}void PushTask(const T& in){//分配任务MutexLock();_q.push(in);MutexUnLock();ThreadWakeUp();//唤醒线程完成任务}~ThreadPool(){pthread_mutex_destroy(&_lock);}
};template<class T>
ThreadPool<T>* ThreadPool<T>::_instance = nullptr;

3️⃣部分问题与细节

下面分享一些在编写该单例模式线程池代码遇到的一些问题与细节:

🔸类成员函数参数列表中隐含的this指针

我们在初始化线程池的这部分代码,需要创建若干线程来完成其所需要执行的任务,这些线程的例程函数形式为void *(*start_routine) (void *) ,其参数列表中仅有一个参数void*,而如果将这个例程函数定义成成员函数,会有一个隐含的this指针参数,导致形式不一致,因此需要将该例程函数用static修饰为静态的。
又因为静态成员函数只能访问静态成员变量,故我们需要在创建线程时将this指针通过参数传递给例程函数,这样才能在例程函数中使用this指针访问类中的成员变量。
在这里插入图片描述

🔸单例模式

我们这个线程池设计成了单例模式,并且采用的是饿汉模式,即服务启动后只有在用到线程池这个功能时才会创建对象。而在单例模式创建对象时,由于只有第一次创建对象时对象指针为nullptr,故判断是否要创建对象指针的时候可以在加锁之前再进行一次判断提高效率,而无需每次都要先加锁再判断。
在这里插入图片描述

🔸一个失误导致的bug

在线程取任务的接口设计时,我因为这里需要访问任务队列这个临界区给这个过程加上了锁,但是实际上在调用这个接口的时候其实线程就已经申请加了锁,而且两次申请的为同一把锁,就导致出现了线程在已经持有一把锁的情况下又去申请这把锁,从而产生了死锁。
在这里插入图片描述

4️⃣调用线程池完成任务

任务类:
实现x 与 y 的+ - * / % 五种运算。

#pragma once
#include <iostream>class Task//x op y = z
{private:int x;int y;char op;//+-*/%public:Task(){}Task(int _x, int _y, char _op):x(_x),y(_y),op(_op){}void operator()(){int z = -1;switch (op){case /* constant-expression */'+':/* code */z = x + y;break;case '-':z = x - y;break;case '*':z = x * y;break;case '/':if(0 != y)z = x / y;elsestd::cout << "warning: div zero error" << std::endl;break;case '%':if(0 != y)z = x % y;elsestd::cout << "warning: div zero error" << std::endl;break;default:std::cout << "unkonwn operator" << std::endl;break;}std::cout << "[" << pthread_self() << "] handler task: " << x << " " << op << " " << y << " = " << z << std::endl;}~Task(){}
};

主函数:

#include "thread_pool.hpp"
#include "Task.hpp"
#include <string>
#include <unistd.h>int main()
{srand((unsigned long)time(nullptr));ThreadPool<Task>* tp = ThreadPool<Task>::getInstance();tp->ThreadPoolInit(5);const std::string s = "+-*/%";while(true){int x = rand() % 50;int y = rand() % 50;char op = s[rand() % 5];Task t(x, y, op);tp->PushTask(t);sleep(1);}return 0;
}

在这里插入图片描述
结果如上,左侧为线程池中的线程每隔一秒取出任务并执行,右侧为线程池的情况。

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

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

相关文章

Python与CAD系列高级篇(二十四)分类提取坐标到excel

目录 0 简述1 分类提取坐标到excel2 结果展示0 简述 本篇介绍以下功能开发:1.对点、直线、多段线、圆、样条曲线分类读取坐标;2.提取坐标到excel。 1 分类提取坐标到excel 需求: ① 用户选择内容。 ② 对选定内容分类提取坐标。 ③ 提取坐标到excel。 代码实现: import m…

Unity填坑-CullingGroup的运用

Unity填坑-CullingGroup的运用 可以使用CullingGroup动态剔除一些对性能有极大影响的脚本、及渲染的进行。 提示&#xff1a;写完文章后&#xff0c;目录可以自动生成&#xff0c;如何生成可参考右边的帮助文档 文章目录 Unity填坑-CullingGroup的运用前言二、示例代码如下总结…

【Linux驱动】设备树中指定中断 | 驱动中获得中断 | 按键中断实验

&#x1f431;作者&#xff1a;一只大喵咪1201 &#x1f431;专栏&#xff1a;《Linux驱动》 &#x1f525;格言&#xff1a;你只管努力&#xff0c;剩下的交给时间&#xff01; 目录 &#x1f3c0;在设备树中指定中断&#x1f3c0;代码中获得中断&#x1f3c0;按键中断⚽驱动…

闪存剩下内容

1&#xff1a;通过Arduino IDE向闪存文件系统上传文件 1. 下载 Arduino-ESP8266闪存文件插件程序 2&#xff1a;使用闪存文件系统建立功能更加丰富的网络服务器 1&#xff1a;在网页中加载闪存文件系统中的图片、CSS和JavaScript index.html&#xff1a;ESP8266开发板建立的网…

SpringBoot+SSM项目实战 苍穹外卖(12) Apache POI

继续上一节的内容&#xff0c;本节是苍穹外卖后端开发的最后一节&#xff0c;本节学习Apache POI&#xff0c;完成工作台、数据导出功能。 目录 工作台Apache POI入门案例 导出运营数据Excel报表 工作台 工作台是系统运营的数据看板&#xff0c;并提供快捷操作入口&#xff0c…

初识OpenCV

首先你得保证你的虚拟机Ubuntu能上网 可看 http://t.csdnimg.cn/bZs6c 打开终端输入 sudo apt-get install libopencv-dev 回车 输入密码 回车 遇到Y/N 回车 OpenCV在线文档 opencv 文档链接 点zip可以下载&#xff0c;点前面的直接在线浏览&#xff0c;但是很慢 https…

c# 视频流压缩

在C#中进行视频流的压缩通常涉及到使用第三方库来处理编解码工作&#xff0c;H.264是一种广泛应用且高效的视频编码标准。以下是一个简化的例子说明如何使用SharpAvi库&#xff08;一个用于生成AVI文件并支持H.264编码的.NET库&#xff09;创建包含H.264编码视频流的AVI文件&am…

Redis的实现四:事件循环和计时器

我们的服务器缺少了一个内容&#xff1a;超时。每个网络应用程序都需要处理超时&#xff0c;因为网络的另一边可能会消失。不要只进行持续的IO操作&#xff0c;如读/写需要超时&#xff0c;但启动空闲的TCP连接也是一个好主意。要实现超时&#xff0c;必须修改事件循环&#xf…

单元测试:Testing leads to failure, and failure leads to understanding

单元测试的概念可能多数读者都有接触过。作为开发人员&#xff0c;我们编写一个个测试用例&#xff0c;测试框架发现这些测试用例&#xff0c;将它们组装成测试 suite 并运行&#xff0c;收集测试报告&#xff0c;并且提供测试基础设施&#xff08;断言、mock、setup 和 teardo…

JAVAEE初阶 文件IO(一)

这里写目录标题 一. 计算机中存储数据的设备1.1 CPU1.2 内存1.3 硬盘1.4 三种存储的区别 二.文件系统2.1 相对路径2.2 绝对路径2.3 .和..的含义2.4 例子2.5 everything工具 三.文件3.1 文本文件3.2 二进制文件 四. JAVA对于文件的API4.1 getParent getName getPath getAbsolute…

Jest单元测试:玩转代码的小捉迷藏!

Jest Jest 是什么&#xff1f; Jest 是一个流行的 JavaScript 测试框架&#xff0c;专注于简化和改进代码的测试流程。它由 Facebook 开发并维护&#xff0c;具有以下特点&#xff1a; 1、易用性&#xff1a;Jest 提供了一个简单而强大的测试框架&#xff0c;使得编写和运行测…

【架构设计】单体软件向微服务化演变

单体软件 假设单体软件的各模块如下&#xff0c;其中服务包含许多功能模块&#xff0c;如用户管理模块、商品模块、订单模块、仓库模块; #mermaid-svg-MzWKwMCwfo3PWMGH {font-family:"trebuchet ms",verdana,arial,sans-serif;font-size:16px;fill:#333;}#mermaid-…

uniapp h5 发行后 微信第二次打开网址 页面白屏

发行后把网址给客户&#xff0c;第一次可以正常登录打开&#xff0c;第二次打开白屏 原因&#xff1a;第一次打开时没有token&#xff0c;所以跳转登录页&#xff0c;可以正常访问 第二次打开时有token&#xff0c;但是网址根目录没有配置默认页面&#xff0c;所以白屏 解决…

Windows Server调整策略实现999999个远程用户用时登录

正文共&#xff1a;1234 字 23 图&#xff0c;预估阅读时间&#xff1a;2 分钟 上篇文章中&#xff08;Windows Server 2019配置多用户远程桌面登录服务器&#xff09;&#xff0c;我们主要介绍了Windows Server 2019在配置远程桌面时&#xff0c;如何通过3种方式创建本地用户账…

微前端无界机制浅析

简介 随着项目的发展&#xff0c;前端SPA应用的规模不断加大、业务代码耦合、编译慢&#xff0c;导致日常的维护难度日益增加。同时前端技术的发展迅猛&#xff0c;导致功能扩展吃力&#xff0c;重构成本高&#xff0c;稳定性低。 为了能够将前端模块解耦&#xff0c;通过相关技…

使用Qt连接scrcpy-server控制手机

Qt连接scrcpy-server 测试环境如何启动scrcpy-server1. 连接设备2. 推送scrcpy-server到手机上3. 建立Adb隧道连接4. 启动服务5. 关闭服务 使用QTcpServer与scrcpy-server建立连接建立连接并视频推流完整流程1. 开启视频推流过程2. 关闭视频推流过程 视频流的解码1. 数据包协议…

python每日学17:控制推导逻辑的子表达式不要超过两个

背景&#xff1a;今天放假在家&#xff0c;《python学习手册》不在身边&#xff0c;所以今天学习《Effective Python: 编写高质量Python代码的90个有效方法》第28条《控制推导逻辑的子表达式不要超过两个》&#xff0c;这本书已经是第二版了&#xff0c;第一版是《编写高质量py…

shell脚本,ADB

Linux命令行命令是系统内置的命令或用户自定义的脚本&#xff08;shell 脚本&#xff0c;.sh扩展名结尾&#xff09;&#xff0c;可以通过终端输入命令来执行。这些命令通常存储在Linux系统的/bin、/usr/bin、/sbin、/usr/sbin等目录下&#xff0c;也可以在$PATH环境变量中指定…

NVMe系统内存结构 - Meta Data

NVMe系统内存结构 - Meta Data 1 为什么需要数据保护2 Meta Data定义3 Meta Data传输方式4 常见Meta Data使用场景4.1 不带数据保护信息4.2 带数据保护信息“数据写”流程4.3 带数据保护信息“数据读”流程4.4 SSD内部加入数据保护信息4.5 SSD内部根据数据保护信息验证数据 本文…

如何在你的网站接入QQ登录?

文章目录 准备阶段申请QQ登录的权限创建应用最后上传qqlogin.php代码 准备阶段 国内服务器和备案域名需要你有张独一无二本人的身份证你正面手持身份证的图片一张100px*100px的网站图标 申请QQ登录的权限 首先访问qq互联&#xff0c;点击我直接访问 登陆完成后我们点击面的…