C#使用Interlocked实现线程同步

 更新时间:2018年10月26日 08:38:12   作者:Czhenya  
今天小编就为大家分享一篇关于C#使用Interlocked实现线程同步,小编觉得内容挺不错的,现在分享给大家,具有很好的参考价值,需要的朋友一起跟随小编来看看吧

通过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# Task

    深入分析C# Task

    这篇文章主要介绍了C# Task的相关资料,文中讲解非常细致,代码帮助大家更好的理解和学习C# Task的相关知识,感兴趣的朋友可以了解下
    2020-08-08
  • Unity3D实现人物转向与移动

    Unity3D实现人物转向与移动

    这篇文章主要为大家详细介绍了Unity3D实现人物转向与移动,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2020-01-01
  • 使用递归实现数组求和示例分享

    使用递归实现数组求和示例分享

    这篇文章主要介绍了使用递归实现数组求和示例,思路是给定一个含有n个元素的整型数组a,求a中所有元素的和,需要的朋友可以参考下
    2014-03-03
  • C#实现Oracle批量写入数据的方法详解

    C#实现Oracle批量写入数据的方法详解

    往数据库批量写入数据,这个功能使用频率相对还是比较高的,特别是在做一些导入等功能的时候。本文为大家介绍了C#实现Oracle批量写入数据的方法,需要的可以参考一下
    2022-11-11
  • C#学习笔记- 浅谈数组复制,排序,取段,元组

    C#学习笔记- 浅谈数组复制,排序,取段,元组

    下面小编就为大家带来一篇C#学习笔记- 浅谈数组复制,排序,取段,元组。小编觉得挺不错的,现在就分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2016-08-08
  • c# SQLHelper(for winForm)实现代码

    c# SQLHelper(for winForm)实现代码

    数据连接池c# SQLHelper 实现代码
    2009-02-02
  • C#如何创建自定义特性

    C#如何创建自定义特性

    这篇文章主要介绍了C#如何创建自定义特性,帮助大家更好的理解和学习使用c#,感兴趣的朋友可以了解下
    2021-04-04
  • C#使用命名管道Pipe进行进程通信实例详解

    C#使用命名管道Pipe进行进程通信实例详解

    这篇文章主要介绍了C#使用命名管道Pipe进行进程通信实例详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2020-12-12
  • C# 递归查找树状目录实现方法

    C# 递归查找树状目录实现方法

    这篇文章主要介绍了C# 递归查找树状目录实现方法,需要的朋友可以参考下
    2014-02-02
  • Unity UGUI的Slider滑动条件组使用详解

    Unity UGUI的Slider滑动条件组使用详解

    这篇文章主要为大家介绍了Unity UGUI的Slider滑动条件组使用详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2023-07-07

最新评论