使用C#怎么实现一个轻量级多线程队列-创新互联

本篇文章给大家分享的是有关使用C#怎么实现一个轻量级多线程队列,小编觉得挺实用的,因此分享给大家学习,希望大家阅读完这篇文章后可以有所收获,话不多说,跟着小编一起来看看吧。

成都创新互联公司-专业网站定制、快速模板网站建设、高性价比江门网站开发、企业建站全套包干低至880元,成熟完善的模板库,直接使用。一站式江门网站制作公司更省心,省钱,快速模板网站建设找我们,业务覆盖江门地区。费用合理售后完善,十余年实体公司更值得信赖。

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

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(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;
 
    /// 
    /// 
    /// 
    /// Thread count
    /// thread free sleep interval
    /// sleep times
 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:有参数无返回

  • Job :有参数有返回, 同时提供执行完成之后返回参数的callback事件。

当然,代码中还有很多地方可以优化,譬如:

  • 当线程处于睡眠中时,有Job需要执行时的interrupt.

  • AddJob方法可以加一些重载。

  • 实现中的事件可以修改为委托,以达到减少一些委托类型的定义。

以上就是使用C#怎么实现一个轻量级多线程队列,小编相信有部分知识点可能是我们日常工作会见到或用到的。希望你能通过这篇文章学到更多知识。更多详情敬请关注创新互联成都网站设计公司行业资讯频道。

另外有需要云服务器可以了解下创新互联scvps.cn,海内外云服务器15元起步,三天无理由+7*72小时售后在线,公司持有idc许可证,提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案,具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势,专为企业上云打造定制,能够满足用户丰富、多元化的应用场景需求。


当前名称:使用C#怎么实现一个轻量级多线程队列-创新互联
地址分享:http://lszwz.com/article/coideo.html

其他资讯

售后响应及时

7×24小时客服热线

数据备份

更安全、更高效、更稳定

价格公道精准

项目经理精准报价不弄虚作假

合作无风险

重合同讲信誉,无效全额退款