当多个线程在并发的时候,难免会碰到相互冲突的事情,比如最经典的ATM机的问题,并发不可怕,可怕的是我们没有能力控制。
线程以我的理解可以分为三种
① 锁。
② 互斥。
③ 信号。
好,这一篇主要整理“锁”,C#提供了2种手工控制的锁
一: Monitor类
这个算是实现锁机制的纯正类,在锁定的临界区中只允许让一个线程访问,其他线程排队等待。主要整理为2组方法。
1:Monitor.Enter和Monitor.Exit
微软很照护我们,给了我们语法糖Lock,对的,语言糖确实减少了我们不必要的劳动并且让代码更可观,但是如果我们要精细的
控制,则必须使用原生类,这里要注意一个问题就是“锁住什么”的问题,一般情况下我们锁住的都是静态对象,我们知道静态对象
属于类级别,当有很多线程共同访问的时候,那个静态对象对多个线程来说是一个,不像实例字段会被认为是多个。
不加锁的情况:
1 class Program
2 {
3 static void Main(string[] args)
4 {
5 for (int i = 0; i < 10; i++)
6 {
7 Thread t = new Thread(Run);
8
9 t.Start();
10 }
11 }
12
13 //资源
14 static object obj = new object();
15
16 static int count = 0;
17
18 static void Run()
19 {
20 Thread.Sleep(10);
21
22 Console.WriteLine("当前数字:{0}", ++count);
23 }
24 }
复制代码
加锁的情况:
1 class Program
2 {
3 static void Main(string[] args)
4 {
5 for (int i = 0; i < 10; i++)
6 {
7 Thread t = new Thread(Run);
8
9 t.Start();
10 }
11 }
12
13 //资源
14 static object obj = new object();
15
16 static int count = 0;
17
18 static void Run()
19 {
20 Thread.Sleep(10);
21
22 //进入临界区
23 Monitor.Enter(obj);
24
25 Console.WriteLine("当前数字:{0}", ++count);
26
27 //退出临界区
28 Monitor.Exit(obj);
29 }
30 }
复制代码
2:Monitor.Wait和Monitor.Pulse
首先这两个方法是成对出现,通常使用在Enter,Exit之间。
Wait: 暂时的释放资源锁,然后该线程进入”等待队列“中,那么自然别的线程就能获取到资源锁。
Pulse: 唤醒“等待队列”中的线程,那么当时被Wait的线程就重新获取到了锁。
这里我们是否注意到了两点:
① 可能A线程进入到临界区后,需要B线程做一些初始化操作,然后A线程继续干剩下的事情。
② 用上面的两个方法,我们可以实现线程间的彼此通信。
下面举个例子来模拟两个人的对话。
1 using System;
2 using System.Collections.Generic;
3 using System.Text;
4 using System.Threading;
5
6 namespace Test
7 {
8 public class Program
9 {
10 public static void Main(string[] args)
11 {
12 LockObj obj = new LockObj();
13
14 //注意,这里使用的是同一个资源对象obj
15 Jack jack = new Jack(obj);
16 John john = new John(obj);
17
18 Thread t1 = new Thread(new ThreadStart(jack.Run));
19 Thread t2 = new Thread(new ThreadStart(john.Run));
20
21 t1.Start();
22 t1.Name = "Jack";
23
24 t2.Start();
25 t2.Name = "John";
26
27 Console.ReadLine();
28 }
29 }
30
31 //锁定对象
32 public class LockObj { }
33
34 public class Jack
35 {
36 private LockObj obj;
37
38 public Jack(LockObj obj)
39 {
40 this.obj = obj;
41 }
42
43 public void Run()
44 {
45 Monitor.Enter(this.obj);
46
47 Console.WriteLine("{0}:我已进入茅厕。", Thread.CurrentThread.Name);
48
49 Console.WriteLine("{0}:擦,太臭了,我还是撤!", Thread.CurrentThread.Name);
50
51 //暂时的释放锁资源
52 Monitor.Wait(this.obj);
53
54 Console.WriteLine("{0}:兄弟说的对,我还是进去吧。", Thread.CurrentThread.Name);
55
56 //唤醒等待队列中的线程
57 Monitor.Pulse(this.obj);
58
59 Console.WriteLine("{0}:拉完了,真舒服。", Thread.CurrentThread.Name);
60
61 Monitor.Exit(this.obj);
62 }
63 }
64
65 public class John
66 {
67 private LockObj obj;
68
69 public John(LockObj obj)
70 {
71 this.obj = obj;
72 }
73
74 public void Run()
75 {
76 Monitor.Enter(this.obj);
77
78 Console.WriteLine("{0}:直奔茅厕,兄弟,你还是进来吧,小心憋坏了!",
79 Thread.CurrentThread.Name);
80
81 //唤醒等待队列中的线程
82 Monitor.Pulse(this.obj);
83
84 Console.WriteLine("{0}:哗啦啦....", Thread.CurrentThread.Name);
85
86 //暂时的释放锁资源
87 Monitor.Wait(this.obj);
88
89 Console.WriteLine("{0}:拉完了,真舒服。", Thread.CurrentThread.Name);
90
91 Monitor.Exit(this.obj);
92 }
93 }
94 }
复制代码
二:ReaderWriterLock类
先前也知道,Monitor实现的是在读写两种情况的临界区中只可以让一个线程访问,那么如果业务中存在”读取密集型“操作,就
好比数据库一样,读取的操作永远比写入的操作多。针对这种情况,我们使用Monitor的话很吃亏,不过没关系,ReadWriterLock
就很牛X,因为实现了”写入串行“,”读取并行“。
ReaderWriteLock中主要用3组方法:
<1> AcquireWriterLock: 获取写入锁。
ReleaseWriterLock:释放写入锁。
<2> AcquireReaderLock: 获取读锁。
ReleaseReaderLock:释放读锁。
<3> UpgradeToWriterLock:将读锁转为写锁。
DowngradeFromWriterLock:将写锁还原为读锁。
下面就实现一个写操作,三个读操作,要知道这三个读操作是并发的。
1 namespace Test
2 {
3 class Program
4 {
5 static List<int> list = new List<int>();
6
7 static ReaderWriterLock rw = new System.Threading.ReaderWriterLock();
8
9 static void Main(string[] args)
10 {
11 Thread t1 = new Thread(AutoAddFunc);
12
13 Thread t2 = new Thread(AutoReadFunc);
14
15 t1.Start();
16
17 t2.Start();
18
19 Console.Read();
20 }
21
22 /// <summary>
23 /// 模拟3s插入一次
24 /// </summary>
25 /// <param name="num"></param>
26 public static void AutoAddFunc()
27 {
28 //3000ms插入一次
29 Timer timer1 = new Timer(new TimerCallback(Add), null, 0, 3000);
30 }
31
32 public static void AutoReadFunc()
33 {
34 //1000ms自动读取一次
35 Timer timer1 = new Timer(new TimerCallback(Read), null, 0, 1000);
36 Timer timer2 = new Timer(new TimerCallback(Read), null, 0, 1000);
37 Timer timer3 = new Timer(new TimerCallback(Read), null, 0, 1000);
38 }
39
40 public static void Add(object obj)
41 {
42 var num = new Random().Next(0, 1000);
43
44 //写锁
45 rw.AcquireWriterLock(TimeSpan.FromSeconds(30));
46
47 list.Add(num);
48
49 Console.WriteLine("我是线程{0},我插入的数据是{1}。", Thread.CurrentThread.ManagedThreadId, num);
50
51 //释放锁
52 rw.ReleaseWriterLock();
53 }
54
55 public static void Read(object obj)
56 {
57 //读锁
58 rw.AcquireReaderLock(TimeSpan.FromSeconds(30));
59
60 Console.WriteLine("我是线程{0},我读取的集合为:{1}",
61 Thread.CurrentThread.ManagedThreadId, string.Join(",", list));
62 //释放锁
63 rw.ReleaseReaderLock();
64 }
65 }
66 }
复制代码
分享到:
相关推荐
Parallel的使用 多线程系列(5)5天不再惧怕多线程——第五天 线程池 5天不再惧怕多线程——第四天 信号量 5天不再惧怕多线程——第三天 互斥体 5天不再惧怕多线程——第二天 锁机制 5天不再惧怕多线程——第一天 尝试...
第5周——第二章——第一节:字体设计的发展.pptx
java上机报告5——Java的多线程编程1
* 支持多线程,保证获取到的连接一定是没有被其他线程正在使用 * 按需创建连接,可以创建多个连接,可以控制连接的数量 * 连接被复用,不是每次都重新创建一个新的连接(连接的创建是一个很消耗资源的过程) * ...
多线程编程之二——MFC中的多线程开发 11 五、MFC对多线程编程的支持 11 六、MFC多线程编程实例 12 例程5 MultiThread5 12 例程6 MultiThread6 15 多线程编程之三——线程间通讯 19 七、线程间通讯 19 例程7 ...
Python爬虫编程基础5天速成——P13——文件处理(csdn)————程序
PyQt5自学记录(1)——PyQt5中多线程实现详解 最近想用PyQt5完成图像识别的一个GUI系统,在调用算法模型进行识别的时候,界面会卡住没有反应,所以想学习一下多线程解决这个问题。然后。。。发现没有基础学习来确实...
定义一个多线程函数5.完整代码 1.实现的功能 代码实现功能,将数据列表中的数据传入,使用四个线程处理,将结果保存在Queue中,线程执行完后,从Queue中获取存储的结果 2.导入线程,队列的标准模块 import threading ...
中考物理复习课件——第二单元:力与运动5-7.ppt
中考物理复习课件——第二单元:力与运动5-7 (2).ppt
Phase Termination——快把玩具收拾好,去睡觉吧 第11章 Thread-Specific Storage——每个线程的保管箱 第12章 Active Object——接受异步消息的主动对象 总结 多线程程序设计的模式语言 附录A 练习问题的解答 附录B...
Java多线程模式详解 目录: 一、漫谈UML Java语言的线程 多线程的评量标准 二、 1、Single Threaded Execution ———— 能通过这座桥的,只有一个人 2、Immutable ———— 想破坏它也没办法 3、Guarded ...
全球V2X技术进展概述——第5届SIP-adus大会(SIP-adus Workshop 2018)车联网综述.pdf
财务管理——第5章.pptx
IEC 62973-5 2023 铁路应用——机车车辆——辅助电源系统用电池——第5部分:锂离子电池.pdf
信号与线性系统——第5章ppt
第4次-3(第5章 单元测试和集成测试——集成测试第4次-3(第5章 单元测试和集成测试——集成测试第4次-3(第5章 单元测试和集成测试——集成测试第4次-3(第5章 单元测试和集成测试——集成测试第4次-3(第5章 单元...
新编计算机网络教程——第5章.ppt
python 2018全国自学考试第2章 第5次做(csdn)————程序