C#使用Interlocked实现线程同步原创
258次浏览
编辑于2022年02月17日 17:01:13
using System; using System.Threading; namespace MultiThread { class Program { //缓冲区,只能容纳一个字符 private static char buffer; //标识量(缓冲区中已使用的空间,初始值为0) private static long numberOfUsedSpace = 0; static void Main(string[] args) { //线程:写入者 Thread Writer = new Thread(delegate () { string str = "这里面的字会一个一个读取出来,一个都不会少,,,"; for (int i = 0; i < 24; i++) { //写入数据前检查缓冲区是否已满 //如果已满,就进行等待,直到缓冲区中的数据被进程Reader读取为止 while (Interlocked.Read(ref numberOfUsedSpace) == 1) { Thread.Sleep(50); } buffer = str[i]; //向缓冲区写入数据 //写入数据后把缓冲区标记为满(由0变为1) Interlocked.Increment(ref numberOfUsedSpace); } }); //线程:读出者 Thread Reader = new Thread(delegate () { for (int i = 0; i < 24; i++) { //读取数据前检查缓冲区是否为空 //如果为空,就进行等待,直到进程Writer向缓冲区中写入数据为止 while (Interlocked.Read(ref numberOfUsedSpace) == 0) { Thread.Sleep(50); } char ch = buffer; //从缓冲区读取数据 Console.Write(ch); Interlocked.Decrement(ref numberOfUsedSpace); } }); //启动线程 Writer.Start(); Reader.Start(); Console.ReadKey(); } } }
推荐阅读