美文网首页
基于C#实现的轻量级多线程队列

基于C#实现的轻量级多线程队列

作者: java编程 | 来源:发表于2019-08-22 14:23 被阅读0次

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

使用Thread异步处理。

使用线程池或Task异步处理。

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

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

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

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

可以设置线程数量,空闲睡眠次数,空闲睡眠时间。空闲睡眠次数和空闲睡眠时间共同控制线程的销毁。

可以设置任务的优先级,提供三种优先级:LOWEST,NORMAL,HIGHEST。

可以设置多线程的模式是使用Thread还是使用Task.

可以提高任务的优先级。

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

输出结果如下

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

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

那么我分别来讲一下QueueManager类的参数

QueueConfirguration类,结构如下。

TaskMaxCount:线程数量,TaskDelay:为空闲时线程睡眠时间(ms单位),delayTimes:睡眠次数

2. QueueTaskMode:枚举类型,提供两种多线程使用方式Thread和Task

3.JobPriorityScheduleConfig:实现接口IJobPriorityScheduleConfig,用来提升Job的优先级。

各位朋友可能也看到了我使用了一个Job类,目前总共有三种Job类型

Job:无参数无返回

Job<T>:有参数无返回

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

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

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

AddJob方法可以加一些重载。

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

相关文章

  • 基于C#实现的轻量级多线程队列

    工作中我们经常会遇到一些一些功能需要实现造作日志,数据修改日志,对于这种业务需求如果我们以同步的方式实现,难免会影...

  • 队列

    基于数组的循环队列 Java实现 基于链表的队列实现 Java实现

  • 基于Redis轻量级队列服务的实现

    前言 常见的消息中间件MQ有很多,如Apache的ActiveMQ,阿里的RocketMQ,使用Erlang编写的...

  • 手敲数据结构——基于最大堆实现优先队列

    这里实现的优先队列是基于最大堆实现的,java系统是基于最小堆实现的。 队列接口 优先队列实现 LeetCode上...

  • python多线程的使用

    python多线程的使用 后续还会更新其他方法实现的多线程。 Queue实现多线程 通过队列实现多线程 启动一定数...

  • 基于Rabbitmq实现延迟队列

    转自 基于Rabbitmq实现延迟队列 基于Rabbitmq实现延迟队列 延迟队列的使用场景 淘宝订单业务:下单后...

  • IOS - 多线程

    多线程实现方案 GCD的队列类型 并发队列自己创建的全局 串行队列主队列自己创建的 NSOperationQueu...

  • JAVA 多线程与高并发学习笔记(十四)——AQS核心原理

    基于 CAS自旋实现的轻量级锁在恶性自旋时会消费大量的CPU资源。解决这个问题有2种方案:分散操作热点和使用队列削...

  • 多线程之NSThread

    什么是NSThreadNSThread是基于线程使用,轻量级的多线程编程方法(相对GCD和NSOperation)...

  • iOS 多线程技术总结

    概览 进程与线程的概念 多线程的由来 并行与并发 多线程的实现 串行与并行 线程的几种状态 串行队列与并发队列区别...

网友评论

      本文标题:基于C#实现的轻量级多线程队列

      本文链接:https://www.haomeiwen.com/subject/sglokxtx.html