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)


相关推荐

  • 初学者学习编程语言应该学习哪一种?

    初学者学习编程语言应该学习哪一种?初学者学习编程语言应该学习哪一种?

  • spring boot redis 缓存_redis本地缓存

    spring boot redis 缓存_redis本地缓存SpringBoot集成Redis缓存查询操作是应用中最常见的操作,如果每次查询都从MySQL中查询则会影响效率,通常需要引入缓存来实现查询性能的优化。缓存可以选择本地缓存,远程缓存或本地缓存结合远程缓存。本地缓存可以使用Guava或Caffeine提供的解决方案,而远程缓存则可以选择Redis这样的内存数据库。本文记录一下SpringBoot集成Redis做缓存的相关配置。1引入依赖引入相应Starter。<dependency><gr

  • initramfs是什么_hdfs工作原理

    initramfs是什么_hdfs工作原理initramfs概述initramfs与initrd类似,也是初始化好了且存在于ram中的,可以压缩也可以不压缩。但是目前initramfs只支持cpio包格式,它会被populate_rootfs->unpack_to_rootfs(&__initramfs_start,&__initramfs_end-&__initramfs_start,0)函数(解压缩、)解析、安装。

  • 常用Lamda表达式

    常用Lamda表达式1、在工作中我们有部分lamda表达式经常会用到,在此做个小总结这里新建个实体类,来做测试publicclassLamdaVO{privateIntegerid;privateStringname;privateStringeamil;publicLamdaVO(){}publicLamdaVO(Integ…

  • Meteor 加入账户系统

    Meteor 加入账户系统

  • C语言内存模型详细介绍_堆栈介绍

    C语言内存模型详细介绍_堆栈介绍(命令行参数区其实就是在通过dos或shell脚本调用时传递的参数,比如:a.exe123123)上图是C语言内存模型,其实虽然说叫C语言内存模型,其实并不是叫C语言内存模型,而是C语言根据CPU处理器搭建出来的一个模型!在开始介绍这些之前,读者需要了解一些体系结构:冯诺依曼体系:把程序本身当作数据来对待,程序指令和该程序处理的数据用同样的方式储存。冯·诺依曼体系结构的要点是:计算机的数制和…

发表回复

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

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