C#使用Interlocked实现线程同步
生活随笔
收集整理的這篇文章主要介紹了
C#使用Interlocked实现线程同步
小編覺得挺不錯的,現(xiàn)在分享給大家,幫大家做個參考.
通過System.Threading命名空間的Interlocked類控制計數(shù)器，從而實現(xiàn)進(jìn)程 的同步。Iterlocked類的部分方法如下表：
示例,同時開啟兩個線程，一個寫入數(shù)據(jù)，一個讀出數(shù)據(jù)
代碼如下：（但是運行結(jié)果卻不是我們想象的那樣）
1 static void Main(string[] args)
2 {
3 //緩沖區(qū)，只能容納一個字符
4 char buffer = ',';
5 string str = ""這里面的字會一個一個讀取出來，一個都不會少，，，"";
6 //線程：寫入數(shù)據(jù)
7 Thread writer = new Thread(() =>
8 {
9 for (int i = 0; i < str.Length; i++)
10 {
11 buffer = str[i];
12 Thread.Sleep(20);
13 }
14 }
15 );
16 //線程：讀出數(shù)據(jù)
17 Thread Reader = new Thread(() =>
18 {
19 for (int i = 0; i < str.Length; i++)
20 {
21 char chartemp = buffer;
22 Console.Write(chartemp);
23 Thread.Sleep(30);
24 }
25 }
26 );
27 writer.Start();
28 Reader.Start();
29 Console.ReadKey();
30 }
運行結(jié)果圖：（每次運行結(jié)果都不一樣）
修改代碼如下：
1 class Program
2 {
3 //緩沖區(qū)，只能容納一個字符
4 private static char buffer;
5 //標(biāo)識量（緩沖區(qū)中已使用的空間，初始值為0）
6 private static long numberOfUsedSpace = 0;
7 static void Main(string[] args)
8 {
9 //線程：寫入者
10 Thread Writer = new Thread(delegate ()
11 {
12 string str = "這里面的字會一個一個讀取出來，一個都不會少，，，";
13 for (int i = 0; i < 24; i++)
14 {
15 //寫入數(shù)據(jù)前檢查緩沖區(qū)是否已滿
16 //如果已滿，就進(jìn)行等待，直到緩沖區(qū)中的數(shù)據(jù)被進(jìn)程Reader讀取為止
17 while (Interlocked.Read(ref numberOfUsedSpace) == 1)
18 {
19 Thread.Sleep(50);
20 }
21 buffer = str[i]; //向緩沖區(qū)寫入數(shù)據(jù)
22 //寫入數(shù)據(jù)后把緩沖區(qū)標(biāo)記為滿（由0變?yōu)?）
23 Interlocked.Increment(ref numberOfUsedSpace);
24 }
25 });
26 //線程：讀出者
27 Thread Reader = new Thread(delegate ()
28 {
29 for (int i = 0; i < 24; i++)
30 {
31 //讀取數(shù)據(jù)前檢查緩沖區(qū)是否為空
32 //如果為空，就進(jìn)行等待，直到進(jìn)程Writer向緩沖區(qū)中寫入數(shù)據(jù)為止
33 while (Interlocked.Read(ref numberOfUsedSpace) == 0)
34 {
35 Thread.Sleep(50);
36 }
37 char ch = buffer; //從緩沖區(qū)讀取數(shù)據(jù)
38 Console.Write(ch);
39 Interlocked.Decrement(ref numberOfUsedSpace);
40 }
41 });
42 //啟動線程
43 Writer.Start();
44 Reader.Start();
45 Console.ReadKey();
46 }
正確結(jié)果圖：
原文地址：https://www.jb51.net/article/149543.htm
總結(jié)
以上是生活随笔為你收集整理的C#使用Interlocked实现线程同步的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： 大数据之路Week10_day01 (通
- 下一篇： python创建项目包