zoukankan      html  css  js  c++  java
  • c# ManualResetEventSlim

    前言

    后续会把异步编程的ManualResetEventSlim 深入写完,先简单介绍一下吧。

    ManualResetEventSlim 有set 方法和 reset 、wait、dispose方法。

    ManualResetEventSlim wait 方法 阻止当前线程,直到设置了当前 ManualResetEventSlim 为止。

    看上图,一个ManualResetEventSlim 可以去给多个线程增加锁。

    他的set 和 reset 就是控制锁的打开和关闭。

    这样解释可能不太理解哈,看下代码。

    正文

    代码:

    static ManualResetEventSlim _mainEvent = new ManualResetEventSlim();
    static void Main(string[] args)
    {
    	var t1 = new Thread(() => TravelThrougnGates("Thead 1", 5));
    	var t2 = new Thread(() => TravelThrougnGates("Thead 2", 6));
    	var t3 = new Thread(() => TravelThrougnGates("Thead 3", 12));
    	t1.Start();
    	t2.Start();
    	t3.Start();
    	Thread.Sleep(TimeSpan.FromSeconds(6));
    	_mainEvent.Set();
    	Thread.Sleep(TimeSpan.FromSeconds(2));
    	_mainEvent.Reset();
    	Console.WriteLine($"_mainEvent is not open");
    	Thread.Sleep(TimeSpan.FromSeconds(10));
    	Console.WriteLine($"_mainEvent is open");
    	_mainEvent.Set();
    	Thread.Sleep(TimeSpan.FromSeconds(2));
    	Console.WriteLine($"_main enter");
    }
    
    static void TravelThrougnGates(string Threadname, int second)
    {
    	Console.WriteLine($"{Threadname} start sleep");
    	Thread.Sleep(TimeSpan.FromSeconds(second));
    	Console.WriteLine($"{Threadname} start running");
    	_mainEvent.Wait();
    	Console.WriteLine($"{Threadname} enter gate");
    }
    

    运行一下,断点位置为:第一个:_mainEvent.Set();

    看下结果:

    也就是说6秒了,但是Thead 1 和 Thead 2 依然没有执行完毕,说明线程被阻塞了。

    然后断点为:_mainEvent.Reset(); 阻塞了:Thead 3。

    执行完毕了Thead 1 和 Thead 2

    然后_mainEvent.Reset();又关闭了,然后阻塞了。

    后续

    补齐原理。

  • 相关阅读:
    Mapreduce实例——求平均值
    Mapreduce实例——单表join
    《短码之美》读书笔记1
    Mapreduce实例——Map端join使用addCacheFile()方法报错,找不到文件
    Mapreduce实例——Map端join
    C# 异常捕获
    Mapreduce实例——排序
    无名
    数据库设计体会
    oracle 删除表空间错误 提示:ora02429:无法删除用于强制唯一/主键的索引。
  • 原文地址:https://www.cnblogs.com/aoximin/p/13219950.html
Copyright © 2011-2022 走看看