欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

基于C#实现的轻量级多线程队列图文详解

程序员文章站 2022-03-11 12:09:16
前言 工作中我们经常会遇到一些一些功能需要实现造作日志,数据修改日志,对于这种业务需求如果我们以同步的方式实现,难免会影响到系统的性能。如下我列出集中解决方案。...

前言

工作中我们经常会遇到一些一些功能需要实现造作日志,数据修改日志,对于这种业务需求如果我们以同步的方式实现,难免会影响到系统的性能。如下我列出集中解决方案。

  1. 使用thread异步处理。
  2. 使用线程池或task异步处理。

以上两种方案确实能解决我们此场景的需求,但是同时也带来了问题。

第一种方式,使用thread的情况下我们无法控制创建的线程数量,要知道创建线程是一个很耗性能的操作。

第二种方式,使用线程池或者task我们虽然可以通过设置线程池的最大线程数量来限制线程最大数,但是这个设置由于是全局的,就会造成所有使用线程池或task的地方都会受到此设置的限制。

当然,第二种方式肯定是优于第一种方式的,我们都是有追求的程序员,做事情当然是追求精益求精。基于此思想的驱动我实现了一个轻量级的多线程队列。她有如下特点:

  1. 可以设置线程数量,空闲睡眠次数,空闲睡眠时间。空闲睡眠次数和空闲睡眠时间共同控制线程的销毁。
  2. 可以设置任务的优先级,提供三种优先级:lowest,normal,highest。
  3. 可以设置多线程的模式是使用thread还是使用task.
  4. 可以提高任务的优先级。

当然首先要说的是使用方法,当我设置使用一个线程的时候如下代码:

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}");

输出结果如下

基于C#实现的轻量级多线程队列图文详解

可以看到使用queuemanager类的线程都是id=4的线程上执行,这是由于我们设置的是一个线程,主线程的id为1,并且可以看到job中的代码是异步执行的。当我们将线程数设置成2的时候输出如下

基于C#实现的轻量级多线程队列图文详解

使用其它是不是很简单??

那么我分别来讲一下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一下,当然也希望各位同仁能提供意见,谢谢。

总结

以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,谢谢大家对的支持。