ManualResetEvent类的用法

ManualResetEvent类的用法ManualResetEvent类作用1.事件初始状态设为false,task线程在第一个WaitOne()处阻塞。2.manualResetEvent.Set()事件状态设为true,task线程在每一个WaitOne()处都不阻塞。3.manualResetEvent调用Set()再调用Reset(),task线程在第一个WaitOne()处阻塞。4.manualResetEvent.Set()事件状态设为true,task线程在第一个WaitOne()处阻塞然后被释放。5.三个线程异步执行,set()

大家好,又见面了,我是你们的朋友全栈君。


在这里插入图片描述

#作用

一个线程通知其他一个或多个线程正在发送的事件。

ManualResetEvent manualResetEvent = new ManualResetEvent(false);

参数表示调用WaitOne()方法的线程是继续执行(true)还是阻塞(false)。

WaitOne():调用WaitOne()方法的线程会阻塞,等待主控线程的manualResetEvent.Set()信号。

Set():将事件状态设为true,调用WaitOne()的线程继续执行。
Reset():将事件状态设为false,调用WaitOne()的线程阻塞。

Set() Reset():只针对WaitOne()方法,不影响WaitOne()方法之前的程序执行。若没有信号,调用WaitOne()方法的线程一直阻塞。

1.事件初始状态设为false,task线程在第一个WaitOne()处阻塞。

using System;
using System.Threading;
using System.Threading.Tasks;
namespace ManualResetEvent测试
{ 
   
    class Program
    { 
   
        static ManualResetEvent manualResetEvent = new ManualResetEvent(false);

        static void Main(string[] args)
        { 
   
            //Task线程和主线程同时执行
            Task task = Task.Factory.StartNew(() =>
            { 
   
                GetDataFromServer(1);
            });
            Console.ReadLine();
        }

        static void GetDataFromServer(int serverNumber)
        { 
   
            Console.WriteLine("I get first data from server" + serverNumber);
            manualResetEvent.WaitOne();
            Console.WriteLine("I get second data from server" + serverNumber);
            Thread.Sleep(TimeSpan.FromSeconds(2));
            Console.WriteLine("I get third data from server" + serverNumber);
            manualResetEvent.WaitOne();
            Console.WriteLine("All the data collected from server" + serverNumber);
        }
    }
}

输出:
I get first data from server1

2.manualResetEvent.Set()事件状态设为true,task线程在每一个WaitOne()处都不阻塞。

namespace ManualResetEvent测试
{ 
   
    class Program
    { 
   
        static ManualResetEvent manualResetEvent = new ManualResetEvent(false);

        static void Main(string[] args)
        { 
   
            //两个Task线程和主线程同时执行
            Task task = Task.Factory.StartNew(() =>
            { 
   
                GetDataFromServer(1);
            });
            
            //主线程执行,将信号set为true,调用WaitOne()的线程被释放
            manualResetEvent.Set();
 
            Console.ReadLine();

        }

        static void GetDataFromServer(int serverNumber)
        { 
   
            Console.WriteLine("I get first data from server" + serverNumber);
            manualResetEvent.WaitOne();
            Console.WriteLine("I get second data from server" + serverNumber);
            Thread.Sleep(TimeSpan.FromSeconds(2));
            Console.WriteLine("I get third data from server" + serverNumber);
            manualResetEvent.WaitOne();
            Console.WriteLine("All the data collected from server" + serverNumber);
        }
    }
}

输出:
I get first data from server1
I get second data from server1
I get third data from server1
All the data collected from server1

3.manualResetEvent调用Set()再调用Reset(),task线程在第一个WaitOne()处阻塞。

namespace ManualResetEvent测试
{ 
   
    class Program
    { 
   
        static ManualResetEvent manualResetEvent = new ManualResetEvent(false);

        static void Main(string[] args)
        { 
   
            //两个Task线程和主线程同时执行
            Task task = Task.Factory.StartNew(() =>
            { 
   
                GetDataFromServer(1);
            });
            
            //主线程执行,调用WaitOne()的线程被释放再马上阻塞
            manualResetEvent.Set();
 			manualResetEvent.Reset();
            Console.ReadLine();

        }

        static void GetDataFromServer(int serverNumber)
        { 
   
            Console.WriteLine("I get first data from server" + serverNumber);
            manualResetEvent.WaitOne();
            Console.WriteLine("I get second data from server" + serverNumber);
            Thread.Sleep(TimeSpan.FromSeconds(2));
            Console.WriteLine("I get third data from server" + serverNumber);
            manualResetEvent.WaitOne();
            Console.WriteLine("All the data collected from server" + serverNumber);
        }
    }
}

输出:
I get first data from server1

4.manualResetEvent.Set()事件状态设为true,task线程在第一个WaitOne()处阻塞然后被释放。

namespace ManualResetEvent测试
{ 
   
    class Program
    { 
   
        static ManualResetEvent manualResetEvent = new ManualResetEvent(false);

        static void Main(string[] args)
        { 
   
            //Task线程和主线程同时执行
            Task task = Task.Factory.StartNew(() =>
            { 
   
                GetDataFromServer(1);
            });

			setEvent.Set();
            manualResetEvent.Reset();

            Thread.Sleep(TimeSpan.FromSeconds(8));
            manualResetEvent.Set();

            Console.ReadLine();
        }

        static void GetDataFromServer(int serverNumber)
        { 
   
            Console.WriteLine("I get first data from server" + serverNumber);
            manualResetEvent.WaitOne();
            Console.WriteLine("I get second data from server" + serverNumber);
            Thread.Sleep(TimeSpan.FromSeconds(2));
            Console.WriteLine("I get third data from server" + serverNumber);
            manualResetEvent.WaitOne();
            Console.WriteLine("All the data collected from server" + serverNumber);
        }
    }
}

输出:
先输出 I get first data from server1
然后task被阻塞,8秒后task获得Set()信号,再输出 I get second data from server1
再间隔2秒输出,第二个WaitOne()不会被阻塞
I get third data from server1
All the data collected from server1

5.三个线程异步执行,set()释放所有线程

namespace ManualResetEvent测试
{ 
   
    class Program
    { 
   
        static ManualResetEvent manualResetEvent = new ManualResetEvent(false);

        static void Main(string[] args)
        { 
   
            //两个Task线程和主线程同时执行
            Task task = Task.Factory.StartNew(() =>
            { 
   
                GetDataFromServer(1);
            });

            Task.Factory.StartNew(() =>
            { 
   
                GetDataFromServer(2);
            });

            manualResetEvent.Set();
            manualResetEvent.Reset();

            Thread.Sleep(TimeSpan.FromSeconds(8));
            manualResetEvent.Set();
            
            Console.ReadLine();

        }

        static void GetDataFromServer(int serverNumber)
        { 
   
            Console.WriteLine("I get first data from server" + serverNumber);
            manualResetEvent.WaitOne();
            Console.WriteLine("I get second data from server" + serverNumber);
            Thread.Sleep(TimeSpan.FromSeconds(2));
            Console.WriteLine("I get third data from server" + serverNumber);
            manualResetEvent.WaitOne();
            Console.WriteLine("All the data collected from server" + serverNumber);
        }
    }
}

输出:
先输出
I get first data from server1
I get first data from server2
然后task被阻塞,8秒后task获得Set()信号,再输出
I get second data from server2
I get second data from server1
再间隔2秒输出,第二个WaitOne()不会被阻塞
I get third data from server2
All the data collected from server2
I get third data from server1
All the data collected from server1

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/161173.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)
blank

相关推荐

  • java months between,java 8-chronounit.months.between(fromdate,todate)不能按预期工作

    java months between,java 8-chronounit.months.between(fromdate,todate)不能按预期工作就日历而言,您的问题是可以理解的:这两个比较代表一个完整的月。但是java.time.temporal.ChronoUnit.between不是以这种方式推理,而是以成套设备.根据它的javadoc,结果是预期的:计算返回一个整数,表示两个时间单位之间的完整单位.例如,中的金额从11:30到13:29的时间只有一个小时一分钟差两个小时。这个LocalDate.untiljavadoc,由Chro…

  • 100个句子记完7000个单词_有趣的童年趣事100字

    100个句子记完7000个单词_有趣的童年趣事100字1.WithmyownearsIclearlyheardtheheartbeatofthenuclearbomb.我亲耳清楚地听到原子弹的心脏的跳动。2.Nextyearthebeardedbearwillbearadearbabyintherear.明年,长胡子的熊将在后方产一头可爱的小崽。3.EarlyIsearchedth

  • 『机器学习笔记 』GBDT原理-Gradient Boosting Decision Tree

    『机器学习笔记 』GBDT原理-Gradient Boosting Decision Tree1.背景1.1GradientBoosting1.2提升树-boostingtree回归问题提升树算法2GradientBoostingDecisionTree2.1函数空间的数值优化2.2算法Shrinkage总结附录参考资料相似算法:1.背景决策树是一种基本的分类与回归方法。决策树模型具有分类速度快,模型…

  • 二分法

    二分法二分法

  • 局域网内实现不同网段ip通信_局域网不同网段互访

    局域网内实现不同网段ip通信_局域网不同网段互访1.使用场景电脑使用网段ip为172.23.0.0/16,设备ip为192.168.1.0/24。将电脑和设备通过交换机连接起来,满足了电脑和设备处于同一局域网不同网段,不能进行网络通信。为了能够进行通信,比如,进行设备的密码重置等,都需要能够通信才能完成。2.参考方案可以在电脑的网络设置里的高级配置中,添加一个和设备处于同一网段的ip。需要注意的是,添加的ip之前要先使用ping命令判断局域网中是否存在相同ip的设备,为了避免ip冲突。有时你会发现ping不通的ip,添加之后也有不通的情况。这

  • 【python】蒙特卡洛树搜索(MCTS)简单实现

    过程包括以下四步:选择Selection:从根节点R开始,递归选择最优的子节点(后面会解释)直到达到叶子节点L。扩展Expansion:如果L不是一个终止节点(也就是,不会导致博弈游戏终止)那么就创建一个或者更多的字子节点,选择其中一个C。模拟Simulation:从C开始运行一个模拟的输出,直到博弈游戏结束。反向传播Backpropagation:用模拟的结果输…

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号