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

2020-01-24 00:13:21

字體：大中小

供稿：網(wǎng)友

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

示例,同時開啟兩個線程，一個寫入數(shù)據(jù)，一個讀出數(shù)據(jù)

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

using System;using System.Threading;namespace 線程同步{  class Program  {    static void Main(string[] args)    {      //緩沖區(qū)，只能容納一個字符      char buffer = ',';      string str = ""這里面的字會一個一個讀取出來，一個都不會少，，，"";      //線程：寫入數(shù)據(jù)      Thread writer = new Thread(() =>      {        for (int i = 0; i < str.Length; i++)        {          buffer = str[i];          Thread.Sleep(20);        }      }             );      //線程：讀出數(shù)據(jù)      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();    }  }}

運行結(jié)果圖：（每次運行結(jié)果都不一樣）

修改代碼如下：

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++)        {          //寫入數(shù)據(jù)前檢查緩沖區(qū)是否已滿          //如果已滿，就進行等待，直到緩沖區(qū)中的數(shù)據(jù)被進程Reader讀取為止          while (Interlocked.Read(ref numberOfUsedSpace) == 1)          {            Thread.Sleep(50);          }          buffer = str[i];  //向緩沖區(qū)寫入數(shù)據(jù)          //寫入數(shù)據(jù)后把緩沖區(qū)標記為滿（由0變?yōu)?）          Interlocked.Increment(ref numberOfUsedSpace);        }      });      //線程：讀出者      Thread Reader = new Thread(delegate ()      {        for (int i = 0; i < 24; i++)        {          //讀取數(shù)據(jù)前檢查緩沖區(qū)是否為空          //如果為空，就進行等待，直到進程Writer向緩沖區(qū)中寫入數(shù)據(jù)為止          while (Interlocked.Read(ref numberOfUsedSpace) == 0)          {            Thread.Sleep(50);          }          char ch = buffer;    //從緩沖區(qū)讀取數(shù)據(jù)          Console.Write(ch);          Interlocked.Decrement(ref numberOfUsedSpace);        }      });      //啟動線程      Writer.Start();      Reader.Start();      Console.ReadKey();    }  }}

正確結(jié)果圖：