本篇文章给大家分享的是有关使用C#怎么实现一个轻量级多线程队列,小编觉得挺实用的,因此分享给大家学习,希望大家阅读完这篇文章后可以有所收获,话不多说,跟着小编一起来看看吧。
创新互联建站坚持“要么做到,要么别承诺”的工作理念,服务领域包括:成都网站制作、网站设计、企业官网、英文网站、手机端网站、网站推广等服务,满足客户于互联网时代的民乐网站设计、移动媒体设计的需求,帮助企业找到有效的互联网解决方案。努力成为您成熟可靠的网络建设合作伙伴!
首先要说的是使用方法,当我设置使用一个线程的时候如下代码:
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}");
输出结果如下
可以看到使用QueueManager类的线程都是id=4的线程上执行,这是由于我们设置的是一个线程,主线程的id为1,并且可以看到Job中的代码是异步执行的。当我们将线程数设置成2的时候输出如下
使用其它是不是很简单??
那么我分别来讲一下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
当然,代码中还有很多地方可以优化,譬如:
当线程处于睡眠中时,有Job需要执行时的interrupt.
AddJob方法可以加一些重载。
实现中的事件可以修改为委托,以达到减少一些委托类型的定义。
以上就是使用C#怎么实现一个轻量级多线程队列,小编相信有部分知识点可能是我们日常工作会见到或用到的。希望你能通过这篇文章学到更多知识。更多详情敬请关注创新互联行业资讯频道。