时间:2021-05-20
通过System.Threading命名空间的Interlocked类控制计数器,从而实现进程 的同步。Iterlocked类的部分方法如下表:
示例,同时开启两个线程,一个写入数据,一个读出数据
代码如下:(但是运行结果却不是我们想象的那样)
using System;using System.Threading;namespace 线程同步{ class Program { static void Main(string[] args) { //缓冲区,只能容纳一个字符 char buffer = ','; string str = ""这里面的字会一个一个读取出来,一个都不会少,,,""; //线程:写入数据 Thread writer = new Thread(() => { for (int i = 0; i < str.Length; i++) { buffer = str[i]; Thread.Sleep(20); } } ); //线程:读出数据 Thread Reader = new Thread(() => { for (int i = 0; i < str.Length; i++) { char chartemp = buffer; Console.Write(chartemp); Thread.Sleep(30); } } ); writer.Start(); Reader.Start(); Console.ReadKey(); } }}运行结果图:(每次运行结果都不一样)
修改代码如下:
using System;using System.Threading;namespace 线程同步{ 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(); } }}正确结果图:
总结
以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,谢谢大家对的支持。如果你想了解更多相关内容请查看下面相关链接
声明:本页内容来源网络,仅供用户参考;我单位不保证亦不表示资料全面及准确无误,也不保证亦不表示这些资料为最新信息,如因任何原因,本网内容或者用户因倚赖本网内容造成任何损失或损害,我单位将不会负任何法律责任。如涉及版权问题,请提交至online#300.cn邮箱联系删除。
本文实例讲述了C#多线程编程之使用ReaderWriterLock类实现多用户读与单用户写同步的方法。分享给大家供大家参考,具体如下:摘要:C#提供了Syste
本文实例讲述了C++使用CriticalSection实现线程同步的方法,在前文C++线程同步实例分析的基础上增加了四行代码,使用了四个函数:EnterCrit
最近捣鼓了一下多线程的同步问题,发现其实C#关于多线程同步事件处理还是很灵活,这里主要写一下,自己测试的一些代码,涉及到了AutoResetEvent和Manu
本文实例讲述了C#实现向多线程传参的三种方式。分享给大家供大家参考,具体如下:从《C#高级编程》了解到给线程传递参数有两种方式,一种方式是使用带Paramete
本文和大家讲一下如何使用C#来创建系统中只能有该程序的一个实例运行。要实现程序的互斥,通常有下面几种方式,下面用C#语言来实现:方法一:使用线程互斥变量.通过定