欢迎来到代码驿站!

.NET代码

当前位置:首页 > 软件编程 > .NET代码

C#使用Interlocked实现线程同步

时间:2020-10-24 11:57:20|栏目:.NET代码|点击:

通过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();
    }
  }
}

正确结果图:

总结

上一篇:把aspx页面伪装成静态html格式的实现代码

栏    目:.NET代码

下一篇:C#中四步轻松使用log4net记录本地日志的方法

本文标题:C#使用Interlocked实现线程同步

本文地址:http://www.codeinn.net/misctech/15374.html

推荐教程

广告投放 | 联系我们 | 版权申明

重要申明:本站所有的文章、图片、评论等,均由网友发表或上传并维护或收集自网络,属个人行为,与本站立场无关。

如果侵犯了您的权利,请与我们联系,我们将在24小时内进行处理、任何非本站因素导致的法律后果,本站均不负任何责任。

联系QQ:914707363 | 邮箱:codeinn#126.com(#换成@)

Copyright © 2020 代码驿站 版权所有