怎么在C#项目中利用Interlocked实现线程同步

本篇文章为大家展示了怎么在C#项目中利用Interlocked实现线程同步，内容简明扼要并且容易理解，绝对能使你眼前一亮，通过这篇文章的详细介绍希望你能有所收获。

企业建站必须是能够以充分展现企业形象为主要目的，是企业文化与产品对外扩展宣传的重要窗口，一个合格的网站不仅仅能为公司带来巨大的互联网上的收集和信息发布平台，成都创新互联公司面向各种领域：成都LED显示屏等网站设计、网络营销推广解决方案、网站设计等建站排名服务。

通过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实现线程同步，你们学到知识或技能了吗？如果还想学到更多技能或者丰富自己的知识储备，欢迎关注创新互联行业资讯频道。