-
C#教程之C#教程之实现一个双缓冲队列(二)
本站最新发布 C#从入门到精通
试听地址 https://www.xin3721.com/eschool/CSharpxin3721/
试听地址 https://www.xin3721.com/eschool/CSharpxin3721/
上一篇(https://www.xin3721.com/ArticlecSharp/c12788.html)实现了一个双缓冲队列的例子,我们把消费者的方法直接写到了队例里,为了达到更好的复用,这一篇分享一个封装的泛型类
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
|
/// <summary> /// 双缓冲队列 /// </summary> /// <typeparam name="T"></typeparam> public class DoubleBufferedQueue<T> : IDisposable { private readonly int _millisecond; /// <summary> /// /// </summary> private readonly Queue<T> _queue1 = new Queue<T>(); private readonly Queue<T> _queue2 = new Queue<T>(); private readonly ManualResetEvent _equeueLock = new ManualResetEvent( true ); private readonly ManualResetEvent _dequeuelock = new ManualResetEvent( false ); private readonly AutoResetEvent _autoReset = new AutoResetEvent( true ); private volatile Queue<T> _currentQueue; private readonly BackgroundWorker _backgroundWorker; /// <summary> /// 双缓冲队列 /// </summary> /// <param name="millisecond">消费者线程处理一批后,需要延时的时间,实现定时间隔操作</param> public DoubleBufferedQueue( int millisecond = 0) { _millisecond = millisecond; _currentQueue = _queue1; _backgroundWorker = new BackgroundWorker(); _backgroundWorker.DoWork += BackgroundWorker_DoWork; _backgroundWorker.RunWorkerAsync(); } /// <summary> /// 消息者处理方法 /// </summary> public Action<Queue<T>> ConsumerAction { get ; set ; } private void BackgroundWorker_DoWork( object sender, DoWorkEventArgs e) { while ( true ) { var readQueue = this .GetDequeue(); ConsumerAction?.Invoke(readQueue); if (_millisecond > 0) Thread.Sleep(TimeSpan.FromMilliseconds(_millisecond)); } // ReSharper disable once FunctionNeverReturns } public void Equeue(T item, Action<T> action = null ) { this ._dequeuelock.WaitOne(); this ._equeueLock.Reset(); _currentQueue.Enqueue(item); action?.Invoke(item); _equeueLock.Set(); _autoReset.Set(); } private Queue<T> GetDequeue() { this ._autoReset.WaitOne(); //这个信号量是保证在没有成员入队列的时间,不进行其它操作 this ._dequeuelock.Reset(); //注意两把锁的顺序,不然会造成死锁的问题 this ._equeueLock.WaitOne(); var readQueue = _currentQueue; _currentQueue = (_currentQueue == _queue1) ? _queue2 : _queue1; this ._dequeuelock.Set(); return readQueue; } public void Dispose() { _dequeuelock.Reset(); ConsumerAction?.Invoke(_queue1); ConsumerAction?.Invoke(_queue2); _backgroundWorker?.Dispose(); } } |
栏目列表
最新更新
如何使用OS模块中的stat方法
Python os 模块
seek() 方法
python打开文件实例1
Python写入文件
什么是流?
文件操作如何进制逐行读取
Python相对路径
with创建临时运行环境
Python文件操作
.Net Standard(.Net Core)实现获取配置信息
Linux PXE + Kickstart 自动装机
Shell 编程 基础
Shell 编程 条件语句
CentOS8-网卡配置及详解
Linux中LVM逻辑卷管理
1.数码相框-相框框架分析(1)
Ubuntu armhf 版本国内源
Linux中raid磁盘阵列
搭建简易网站
access教程之Access简介
mysql 安装了最新版本8.x版本后的报错:
Mysql空间数据&空间索引(spatial)
如何远程连接SQL Server数据库的图文教程
复制SqlServer数据库的方法
搜索sql语句
sql中返回参数的值
sql中生成查询的模糊匹配字符串
数据定义功能
数据操作功能