基于C#实现的轻量级多线程队列图文详解
前言
工作中我们经常会遇到一些一些功能需要实现造作日志,数据修改日志,对于这种业务需求如果我们以同步的方式实现,难免会影响到系统的性能。如下我列出集中解决方案。
- 使用Thread异步处理。
- 使用线程池或Task异步处理。
以上两种方案确实能解决我们此场景的需求,但是同时也带来了问题。
第一种方式,使用thread的情况下我们无法控制创建的线程数量,要知道创建线程是一个很耗性能的操作。
第二种方式,使用线程池或者Task我们虽然可以通过设置线程池的最大线程数量来限制线程最大数,但是这个设置由于是全局的,就会造成所有使用线程池或Task的地方都会受到此设置的限制。
当然,第二种方式肯定是优于第一种方式的,我们都是有追求的程序员,做事情当然是追求精益求精。基于此思想的驱动我实现了一个轻量级的多线程队列。她有如下特点:
- 可以设置线程数量,空闲睡眠次数,空闲睡眠时间。空闲睡眠次数和空闲睡眠时间共同控制线程的销毁。
- 可以设置任务的优先级,提供三种优先级:LOWEST,NORMAL,HIGHEST。
- 可以设置多线程的模式是使用Thread还是使用Task.
- 可以提高任务的优先级。
当然首先要说的是使用方法,当我设置使用一个线程的时候如下代码:
var manager = new QueueManager(new QueueConfirguration(1, 10000, 1), QueueTaskMode.Task, new JobPriorityScheduleConfig(DateTime.Now, new TimeSpan(0, 1, 0))); manager.Start(); for (int i = 0; i < 20; i++) { manager.AddJob(new Job<int>(i,(index) => { Console.WriteLine($"线程id:{System.Threading.Thread.CurrentThread.ManagedThreadId} 当前序号:{index}"); })); } Console.WriteLine($"主线程ID:{System.Threading.Thread.CurrentThread.ManagedThreadId}");
输出结果如下
可以看到使用QueueManager类的线程都是id=4的线程上执行,这是由于我们设置的是一个线程,主线程的id为1,并且可以看到Job中的代码是异步执行的。当我们将线程数设置成2的时候输出如下
使用其它是不是很简单??
那么我分别来讲一下QueueManager类的参数
1. QueueConfirguration类,结构如下。
public class QueueConfirguration : IQueueConfirguration { private int taskMaxCount; private int taskDelay; private int delayTimes; /// <summary> /// /// </summary> /// <param name="taskMaxCount">Thread count</param> /// <param name="taskDelay">thread free sleep interval</param> /// <param name="delayTimes">sleep times</param> public QueueConfirguration(int taskMaxCount, int taskDelay, int delayTimes) { this.taskMaxCount = taskMaxCount; this.taskDelay = taskDelay; this.delayTimes = delayTimes; } public int TaskMaxCount { get { return this.taskMaxCount; } } public int TaskDelay { get { return this.taskDelay; } } public int DelayTimes { get { return this.delayTimes; } } }
TaskMaxCount:线程数量,TaskDelay:为空闲时线程睡眠时间(ms单位),delayTimes:睡眠次数
2. QueueTaskMode:枚举类型,提供两种多线程使用方式Thread和Task
3.JobPriorityScheduleConfig:实现接口IJobPriorityScheduleConfig,用来提升Job的优先级。
各位朋友可能也看到了我使用了一个Job类,目前总共有三种Job类型
- Job:无参数无返回
- Job<T>:有参数无返回
- Job<T1, T2> :有参数有返回, 同时提供执行完成之后返回参数的callback事件。
当然,代码中还有很多地方可以优化,譬如:
- 当线程处于睡眠中时,有Job需要执行时的interrupt.
- AddJob方法可以加一些重载。
- 实现中的事件可以修改为委托,以达到减少一些委托类型的定义。
具体代码可以访问我的github仓储:https://github.com/Roger3Lee/INC.Runtime.Queue 查看。如果喜欢还请Star一下,当然也希望各位同仁能提供意见,谢谢。
总结
以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,谢谢大家对脚本之家的支持。
- MongoDB副本(一主一备+仲裁)环境部署记录
- 根据前后的子串求中间串的函数
- Centos6下zookeeper集群部署记录
- 抓取百度指数引发的图像数字识别
- 真正将标注文字遮盖的方法
- “AS3.0高级动画编程”学习:第四章 寻路(AStar/A星/A*)算法 (中)
- li浮动时ul高度为0,解决ul自适应高度的几种方法
- 使用正则表达式求完整路径中的文件名
- “AS3.0高级动画编程”学习:第四章 寻路(AStar/A星/A*)算法 (下)
- Centos下SFTP双机高可用环境部署记录
- as3:Function以及call,apply
- centos6下redis cluster集群部署过程
- centos6下ActiveMQ+Zookeeper消息中间件集群部署记录
- 发布一个轻量级的滑块控件
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- 在nodejs服务器和ABAP服务器上使用jsonp
- 如何在Android平台上创建自定义的Cordova插件并使用SAP UI5消费
- 使用SAP BSP应用运行Vue
- 微信开发系列之六 - 使用微信OAuth2 API读取微信用户信息,显示在SAP UI5里
- 微信开发系列之五 - 将SAP UI5应用嵌入到微信中
- 微信开发系列之四 - 将SAP C4C的数据更改通知发送到微信公众号上
- 微信开发系列之三 - 在微信公众号里发起SAP C4C Account的创建
- 微信开发系列之二 - 在微信公众号里开发一个自动应答的图灵机器人
- 微信开发系列之一 - 微信公众号开发的开发环境搭建
- SAP Commerce开发之如何找到某个页面对应的JSP实现页面
- 如何用代码读取SAP CRM的Categorization Schema
- 如何使用代码创建SAP CRM Service Request subject
- 微信开发系列之八 - 微信公众号的地图集成
- vivo 悟空活动中台 - 栅格布局方案
- 使用literal或者绑定变量执行SAP HANA SQL语句