C#使用Interlocked实现线程同步原创
金蝶云社区-云社区用户26064194
云社区用户26064194
0人赞赏了该文章 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();
    }
  }
}


image.png


image.png

赞 0