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

來源：本站原創(chuàng)|時(shí)間：2020-01-10|欄目：C#教程|點(diǎn)擊：次

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

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

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

using System;
using System.Threading;
namespace 線程同步
{
  class Program
  {
    static void Main(string[] args)
    {
      //緩沖區(qū)，只能容納一個(gè)字符
      char buffer = ',';
      string str = ""這里面的字會(huì)一個(gè)一個(gè)讀取出來，一個(gè)都不會(huì)少，，，"";
      //線程：寫入數(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();
    }
  }
}

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

修改代碼如下：

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

正確結(jié)果圖：

總結(jié)

以上就是這篇文章的全部?jī)?nèi)容了，希望本文的內(nèi)容對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，謝謝大家對(duì)我們的支持。如果你想了解更多相關(guān)內(nèi)容請(qǐng)查看下面相關(guān)鏈接

上一篇：C#計(jì)時(shí)器的三種實(shí)現(xiàn)方法

欄目：C#教程

下一篇：C# datagrid非常規(guī)方法實(shí)現(xiàn)添加合并列

本文標(biāo)題：C#使用Interlocked實(shí)現(xiàn)線程同步

本文地址：http://www.jygsgssxh.com/a1/C_jiaocheng/5021.html

更多C#教程

雷火电竞-中国电竞赛事及体育赛事平台

C#教程

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

您可能感興趣的文章

閱讀排行

本欄相關(guān)

隨機(jī)閱讀