C# 线程同步的方法线程同步的方法
一、进程内部的线程同步一、进程内部的线程同步
1、使用、使用lock,用法如下:,用法如下:
private static readonly object SeqLock = new object();
private void Print()
{
lock (SeqLock)
{
Console.WriteLine("test");
}
}
特性:只能传递对象,无法设置等待超时
2、使用:、使用:InterLocked(原子操作)(原子操作)
其在System.Threading命名空间下,Interlocked实际是类控制计数器,从而实现进程的同步,其很容易实现生产者消费者模型
//缓冲区,只能容纳一个字符
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();
3、使用、使用Monitor
其中Monitor.Enter()和lock相同
Monitor.Enter(obj){
//Synchronized part
}finally{
Monitor.Exit(obj);
评论0