C#使用Interlocked實現(xiàn)線程同步

更新時間：2018年10月26日 08:38:12 作者：Czhenya

今天小編就為大家分享一篇關于C#使用Interlocked實現(xiàn)線程同步，小編覺得內容挺不錯的，現(xiàn)在分享給大家，具有很好的參考價值，需要的朋友一起跟隨小編來看看吧

通過System.Threading命名空間的Interlocked類控制計數器，從而實現(xiàn)進程的同步。Iterlocked類的部分方法如下表：

示例,同時開啟兩個線程，一個寫入數據，一個讀出數據

代碼如下：（但是運行結果卻不是我們想象的那樣）

using System;
using System.Threading;
namespace 線程同步
{
  class Program
  {
    static void Main(string[] args)
    {
      //緩沖區(qū)，只能容納一個字符
      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
  {
    //緩沖區(qū)，只能容納一個字符
    private static char buffer;
    //標識量（緩沖區(qū)中已使用的空間，初始值為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++)
        {
          //寫入數據前檢查緩沖區(qū)是否已滿
          //如果已滿，就進行等待，直到緩沖區(qū)中的數據被進程Reader讀取為止
          while (Interlocked.Read(ref numberOfUsedSpace) == 1)
          {
            Thread.Sleep(50);
          }
          buffer = str[i];  //向緩沖區(qū)寫入數據
          //寫入數據后把緩沖區(qū)標記為滿（由0變?yōu)?）
          Interlocked.Increment(ref numberOfUsedSpace);
        }
      });
      //線程：讀出者
      Thread Reader = new Thread(delegate ()
      {
        for (int i = 0; i < 24; i++)
        {
          //讀取數據前檢查緩沖區(qū)是否為空
          //如果為空，就進行等待，直到進程Writer向緩沖區(qū)中寫入數據為止
          while (Interlocked.Read(ref numberOfUsedSpace) == 0)
          {
            Thread.Sleep(50);
          }
          char ch = buffer;    //從緩沖區(qū)讀取數據
          Console.Write(ch);
          Interlocked.Decrement(ref numberOfUsedSpace);
        }
      });
      //啟動線程
      Writer.Start();
      Reader.Start();
      Console.ReadKey();
    }
  }
}

正確結果圖：