Linux|多线程（三）

线程池

线程池是一种多线程处理形式，处理过程中它将被提交的任务分配给预先创建好的多个线程中的一个去执行。

线程池的实现

#pragma once
#include <pthread.h>
#include <vector>
#include <string>
#include <unistd.h>
#include <pthread.h>
#include <queue>
#include <functional>
#include "task.hpp"
#include "thread.hpp"
using namespace ThreadModel;
// void test(const std::string &name)
// {//     while (1)
//     {
//         std::cout << name << "is running.." << std::endl;
//         sleep(1);
//     }
// }
const int Default_nums = 3;template <class T>
class ThreadPool
{using func_t = std::function<void(const std::string name)>;private:bool isEmpty(){return _task_queue.size() == 0;}void Sleep(){pthread_cond_wait(&_cond, &_mutex);}void lockQueue(){pthread_mutex_lock(&_mutex);}void wakeUp(){pthread_cond_signal(&_cond);}void wakeUpAll(){pthread_cond_broadcast(&_cond);}void unlockQueue(){pthread_mutex_unlock(&_mutex);}void hadertask(const std::string name){lockQueue();while (true){while (isEmpty() && _isrunning){_sleepnums++;std::cout << name << " star sleep" << std::endl;Sleep();std::cout << name << " awaken" << std::endl;_sleepnums--;}if (isEmpty() && !_isrunning){unlockQueue();std::cout << name << " quit" << std::endl;break;}T t = _task_queue.front();_task_queue.pop();unlockQueue();t();std::cout << t.solve() << std::endl;}}void init(){// 并将调用func时的第一个参数传递给hander函数。func_t func = std::bind(&ThreadPool::hadertask, this, std::placeholders::_1);for (int i = 0; i < _thread_nums; i++){std::string name = "thread-" + std::to_string(i + 1);_threads.emplace_back(name, func);std::cout << name << " init sucess" << std::endl;}}ThreadPool(int thread_nums = Default_nums) : _thread_nums(thread_nums), _sleepnums(0){init();pthread_mutex_init(&_mutex, nullptr);pthread_cond_init(&_cond, nullptr);}public:~ThreadPool(){pthread_cond_destroy(&_cond);pthread_mutex_destroy(&_mutex);}static ThreadPool<T> * GetInstance(int thread_nums = Default_nums){if (_tp == nullptr){pthread_mutex_lock(&_sig_mutx);if (_tp == nullptr){_tp = new ThreadPool(thread_nums);std::cout<<"create instance"<<std::endl;}pthread_mutex_unlock(&_sig_mutx);}std::cout<<"get instance"<<std::endl;return _tp;}void start(){_isrunning = true;std::cout << "threadpool is running:" << std::endl;for (auto &thread : _threads) // 这个引用特别重要// 如果不传引用 thread 出了函数会被销毁 访问name 会出问题{thread.start();}}void equeue(const T &in){// 拿数据和放数据要加锁 因为可能脏读lockQueue();if (_isrunning){_task_queue.push(in);if (_sleepnums > 0){wakeUp();}}std::cout << in.inquiry() << std::endl;unlockQueue();}void stop(){wakeUpAll();std::cout << "threadpool stop" << std::endl;_isrunning = false;}private:std::queue<T> _task_queue;int _thread_nums;std::vector<Thread> _threads;bool _isrunning;int _sleepnums;pthread_mutex_t _mutex;pthread_cond_t _cond;static ThreadPool *_tp;static pthread_mutex_t _sig_mutx;
};
template <class T>
ThreadPool<T> *ThreadPool<T>::_tp = nullptr;template <class T>
pthread_mutex_t ThreadPool<T>::_sig_mutx = PTHREAD_MUTEX_INITIALIZER;

日志类

#pragma once
#include <iostream>
#include <string>
#include <unistd.h>
#include <sys/types.h>
#include <ctime>
#include <stdarg.h>
#include <fstream>
#include <cstring>
#include <pthread.h>
#include "lockerguard.hpp"
// namespace{}
namespace log_ns
{
#define SCREEN_TYPE 1
#define FILE_TYPE 2pthread_mutex_t gmutex = PTHREAD_MUTEX_INITIALIZER;enum level{DEBUG = 1,INFO,WARNNING,ERROR,FATAL};std::string levelToString(int level){switch (level){case DEBUG:return "DEBUG";case INFO:return "INFO";case WARNNING:return "WARNNING";case ERROR:return "ERROR";case FATAL:return "FATAL";default:return "UNKNOW";}}std::string GetCurTime(){time_t now = time(nullptr);struct tm *cur_time = localtime(&now);char buff[128];snprintf(buff, 128, "%d-%02d-%02d %02d:%02d:%02d",cur_time->tm_year + 1900,cur_time->tm_mon + 1,cur_time->tm_mday,cur_time->tm_hour,cur_time->tm_min,cur_time->tm_sec);return buff;}class LogMessage{public:std::string _level;        // 日志等级pid_t _id;                 // 进程号std::string _filename;     // 文件名int _filenumber;           // 行号std::string _cur_time;     // 日志所写时间std::string _message_info; // 日志信息};const char *gfile = "./log.txt";class Log{public:Log(const std::string &logfile = gfile) : _logFile(logfile), _type(SCREEN_TYPE){}void FlushLogToScreen(const LogMessage &lg){printf("[%s][%d][%s][%d][%s] %s",lg._level.c_str(),lg._id,lg._filename.c_str(),lg._filenumber,lg._cur_time.c_str(),lg._message_info.c_str());}void FlushLogToFile(const LogMessage &lg){//std::ofstream out(_logFile, std::ios::app);if (!out.is_open())return;char buff[1024];snprintf(buff, sizeof(buff), "[%s][%d][%s][%d][%s] %s",lg._level.c_str(),lg._id,lg._filename.c_str(),lg._filenumber,lg._cur_time.c_str(),lg._message_info.c_str());out.write(buff, strlen(buff));out.close();}void FlushLog(const LogMessage &lg){LockGuard lockguard(&gmutex);switch (_type){case SCREEN_TYPE:FlushLogToScreen(lg);break;case FILE_TYPE:FlushLogToFile(lg);break;default:break;}}void logMessage(int level, std::string filename, int filenumber, const char *format...){LogMessage lg;lg._level = levelToString(level);lg._filename = filename;lg._filenumber = filenumber;lg._cur_time = GetCurTime();lg._id = getpid();va_list ap;va_start(ap, format);char buff[128];vsnprintf(buff, sizeof(buff), format, ap);va_end(ap);FlushLog(lg);}private:int _type;std::string _logFile;};Log lg;
#define LOG(Level, Format, ...)                                          \do                                                                   \{                                                                    \lg.logMessage(Level, __FILE__, __LINE__, Format, ##__VA_ARGS__); \} while (0)
#define EnableScreen()          \do                          \{                           \lg.Enable(SCREEN_TYPE); \} while (0)
#define EnableFile()          \do                        \{                         \lg.Enable(FILE_TYPE); \} while (0)
}

单例模式

 static ThreadPool<T> * GetInstance(int thread_nums = Default_nums){if (_tp == nullptr){pthread_mutex_lock(&_sig_mutx);if (_tp == nullptr){_tp = new ThreadPool(thread_nums);std::cout<<"create instance"<<std::endl;}pthread_mutex_unlock(&_sig_mutx);}std::cout<<"get instance"<<std::endl;return _tp;}

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

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

相关文章

Conda pack 进行Python环境打包

Conda pack 进行Python环境打包

大模型相关目录 大模型&#xff0c;包括部署微调prompt/Agent应用开发、知识库增强、数据库增强、知识图谱增强、自然语言处理、多模态等大模型应用开发内容 从0起步&#xff0c;扬帆起航。 基于Dify的智能分类方案&#xff1a;大模型结合KNN算法&#xff08;附代码&#xff…
阅读更多...
第一次CCF计算机软件能力认证

第一次CCF计算机软件能力认证

AcWing 3197. 相反数 有 N 个非零且各不相同的整数。 请你编一个程序求出它们中有多少对相反数(a 和 −a 为一对相反数)。 输入格式 第一行包含一个正整数 N。 第二行为 N 个用单个空格隔开的非零整数&#xff0c;每个数的绝对值不超过 1000&#xff0c;保证这些整数各不相同。…
阅读更多...
使用netty编写syslog日志接收服务端

使用netty编写syslog日志接收服务端

使用netty编写syslog日志接收服务端 1.添加netty依赖 <dependency><groupId>io.netty</groupId><artifactId>netty-all</artifactId><version>4.1.72.Final</version> <!-- 版本号可能需要根据实际情况更新 --></dependenc…
阅读更多...
Docker Desktop安装（通俗易懂）

Docker Desktop安装（通俗易懂）

1、官网 https://www.docker.com/products/docker-desktop/ 2、阿里云镜像 docker-toolbox-windows-docker-for-windows安装包下载_开源镜像站-阿里云 1. 双击安装文件勾选选项 意思就是&#xff1a; Use WSL 2 instead of Hyper-V (recommended) : 启用虚拟化&#xff0c;…
阅读更多...
重生之“我打数据结构，真的假的？”--4.二叉树

重生之“我打数据结构，真的假的？”--4.二叉树

1.对称二叉树 . - 力扣&#xff08;LeetCode&#xff09; 思路 &#xff1a; 1.设置两个队列l&#xff0c;r&#xff0c;先将root的左节点入l&#xff0c;右节点入r。 2.分别出队&#xff0c;若出队元素相同 Queuepush(&l, front->left); Queuepush(&l, front->…
阅读更多...
调度器——DolphinScheduler讲解及安装教程

调度器——DolphinScheduler讲解及安装教程

调度器——DolphinScheduler讲解及安装教程 一&#xff1a;基本讲解 Dolphin Scheduler 1、开源的分布式任务调度系统 2、支持多种任务类型&#xff0c;包括Shell、Spark、Hive等 3、灵活的任务调度功能和友好的Web界面&#xff0c;方便管理和监控任务的执行情况 架构 操作系…
阅读更多...
idea 自动生成pojo类

idea 自动生成pojo类

找到这个View>Tool Windows>Database配置数据库 配置好后刷新&#xff0c;查看是否连接上表 然后找到 点击后选择你将要生成的pojo需要保存到哪个文件&#xff0c;然后再次点击&#xff0c;就生成好了&#xff0c;然后自己稍作修改即可使用该pojo类了
阅读更多...
nginx的配置：TLSv1 TLSv1.1 被暴露不安全

nginx的配置：TLSv1 TLSv1.1 被暴露不安全

要在 Nginx 配置中禁用不安全的 SSL 协议&#xff08;如 TLSv1 和 TLSv1.1&#xff09;&#xff0c;并仅启用更安全的协议&#xff08;如 TLSv1.2 和 TLSv1.3&#xff09;&#xff0c;您可以更新您的 Nginx 配置文件。下面是一个示例配置&#xff1a; # 位于 Nginx 配置文件 (…
阅读更多...
Vue3可媲美Element Plus Tree组件实战之移除节点

Vue3可媲美Element Plus Tree组件实战之移除节点

Element Plus Tree自定义节点内容示例中介绍了移除节点的用法&#xff0c;个人觉得作为提供给用户API&#xff0c;应该遵循迪米特法则&#xff0c;把功能实现的细节封装在组件内部&#xff0c;而提供给用户最简单的操作方式&#xff0c;同时在此基础上支持用户的扩展。 因此&a…
阅读更多...
【python学习】思考-如何在PyCharm中编写一个简单的Flask应用示例以及如何用cProfile来对Python代码进行性能分析

【python学习】思考-如何在PyCharm中编写一个简单的Flask应用示例以及如何用cProfile来对Python代码进行性能分析

引言 Python中有两个流行的Web框架&#xff1a;Django和Flask。Django是一个高级的Python Web框架&#xff0c;它鼓励快速开发和干净、实用的设计&#xff1b;Flask是一个轻量级的Web应用框架&#xff0c;适用于小型到大型应用。以下是使用Flask创建一个简单应用的基本步骤cPro…
阅读更多...
从工业到航空：旋转花键跨行业的多样用途解析！

从工业到航空：旋转花键跨行业的多样用途解析！

旋转花键是一种新型的高效传动元件&#xff0c;主要由内花键和外花键组成。内花键和外花键之间放置着一排排滚珠&#xff0c;当内花键和外花键相对旋转时&#xff0c;滚珠在内、外花键之间滚动&#xff0c;从而实现动力的传递。 旋转花键的基本功能主要是用于连接轴和套的旋转部…
阅读更多...
前端位运算运用场景小知识（权限相关）

前端位运算运用场景小知识（权限相关）

前提&#xff1a;此篇结合AI、公司实际业务产出&#xff0c;背景是公司有个业务涉及权限&#xff0c;用位运算来控制的&#xff0c;比较新奇&#xff0c;所以记录一下(可能自己比较low) 前端js位运算一般实际的应用场景在哪 ai回答&#xff1a; 整数运算与性能优化&#xff…
阅读更多...
mmdetection训练后评估指标，验证Loss

mmdetection训练后评估指标，验证Loss

项目场景&#xff1a; 对mmdetection框架下训练好的log.json文件进行评估。 问题描述 使用框架底下自带的评估文件&#xff0c;不能对loss进行评估。也就是文件&#xff1a;tools/analysis_tools/analyze_logs.py 解决方案&#xff1a; 自己做了评估loss的代码&#xff0c;目…
阅读更多...
力扣94题（java语言）

力扣94题（java语言）

题目 思路 使用一个栈来模拟递归的过程&#xff0c;以非递归的方式完成中序遍历(使用栈可以避免递归调用的空间消耗)。 遍历顺序步骤&#xff1a; 遍历左子树访问根节点遍历右子树 package algorithm_leetcode;import java.util.ArrayList; import java.util.List; import…
阅读更多...
重磅发布：OpenAI宣布推出AI驱动的搜索引擎SearchGPT，将与Google和Perplexity展开竞争｜TodayAI

重磅发布：OpenAI宣布推出AI驱动的搜索引擎SearchGPT，将与Google和Perplexity展开竞争｜TodayAI

OpenAI宣布推出其备受期待的AI驱动搜索引擎SearchGPT。该搜索引擎能够实时访问互联网信息&#xff0c;并将作为原型在有限范围内发布&#xff0c;计划最终将其功能整合到ChatGPT中。 SearchGPT的功能特点 SearchGPT是一个具有实时互联网信息访问能力的AI驱动搜索引擎。它的界面…
阅读更多...
轨道式智能巡检机器人，助力综合管廊安全运维

轨道式智能巡检机器人，助力综合管廊安全运维

1 引言 当前城市综合管廊建设已经成为世界范围内的发展趋势&#xff0c;2017年5月住建部、发改委联合发布《全国城市市政基础设施建设“十三五”规划》&#xff0c;截至2017年4月底国内地下综合管廊试点项目已开工建设687 km&#xff0c;建成廊体260 km&#xff0c;完成投资40…
阅读更多...
用python程序发送文件（python实例二十六）

用python程序发送文件（python实例二十六）

目录 1.认识Python 2.环境与工具 2.1 python环境 2.2 Visual Studio Code编译 3.文件上传 3.1 代码构思 3.2 服务端代码 3.3 客户端代码 3.4 运行结果 4.总结 1.认识Python Python 是一个高层次的结合了解释性、编译性、互动性和面向对象的脚本语言。 Python 的设计具…
阅读更多...
C++图网结构算法

C++图网结构算法

目录 一.迪杰斯特拉算法&#xff08;dijkstra&#xff09; 1.实现原理&#xff1a; 2.代码实现&#xff1a; 3.例题&#xff1a; 二.spfa算法&#xff1a; 1.实现原理&#xff1a; 2.代码实现&#xff1a; 3.例题&#xff1a; 三.贝尔曼福特&#xff08;bellman_ford&…
阅读更多...
ASP.NET Core应用程序的生存期事件

ASP.NET Core应用程序的生存期事件

ASP.NET Core应用程序的生存期事件是指在ASP.NET Core应用程序运行过程中&#xff0c;按照特定顺序触发的一系列事件。这些事件允许开发者在应用程序生命周期的不同阶段执行自定义代码&#xff0c;以进行初始化、资源清理、日志记录等操作。以下是对ASP.NET Core应用程序生存期…
阅读更多...
【嵌入式硬件】快衰减和慢衰减

【嵌入式硬件】快衰减和慢衰减

1.引语 在使用直流有刷电机驱动芯片A4950时，这款芯片采用的是PWM控制方式，我发现他的正转、反转有两种控制方式，分别是快衰减和慢衰减。 2.理解 慢衰减：相当于加在电机(感性原件)两端电压消失，将电机两端正负短接。 快衰减：相当于加在电机(感性原件)两端电压消失，将电机…
阅读更多...
最新文章

Copyright @ 2022~2023