C#使用Interlocked实现线程同步

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);
}
});
//线程:读出者
ThreC#使用Interlocked实现线程同步
using System;using System.Threading;namespace MultiThread{ class Program { //缓冲区,只能容纳一个字符 private static char ...
点击下载文档文档为doc格式
声明:除非特别标注,否则均为本站原创文章,转载时请以链接形式注明文章出处。如若本站内容侵犯了原著者的合法权益,可联系本站删除。
上一篇
已经是第一篇



