本篇文章为大家展示了怎么在C#项目中利用Interlocked实现线程同步,内容简明扼要并且容易理解,绝对能使你眼前一亮,通过这篇文章的详细介绍希望你能有所收获。
通过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();
}
}
}
正确结果图:
上述内容就是怎么在C#项目中利用Interlocked实现线程同步,你们学到知识或技能了吗?如果还想学到更多技能或者丰富自己的知识储备,欢迎关注亿速云行业资讯频道。
亿速云「云服务器」,即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘,价格低至29元/月。点击查看>>
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。