WaitHandle——使用ManualResetEvent

简介: 信号量机制     使用ManualResetEvent和AutoResetEvent都继承自EventWaitHandle(继承自waitHandle)。EventWaitHandle对象有两个状态:收到信号(signaled)和未收到信号(nonsignaled);EventWaitHandle中的set和reset方法分别用于将eventwaitHandle对象的状态设为收到信号和未收到信号。

信号量机制



    使用ManualResetEvent和AutoResetEvent都继承自EventWaitHandle(继承自waitHandle)。EventWaitHandle对象有两个状态:收到信号(signaled)和未收到信号(nonsignaled);EventWaitHandle中的set和reset方法分别用于将eventwaitHandle对象的状态设为收到信号和未收到信号。

     当EventWaitHandle未收到信号时,任何线程调用基类的wait方法都会被阻塞,知道eventhandle对象的状态变为收到信号。

      ManualResetEvent的构造函数接受一个布尔类型,用于设置ManualResetEvent对象的初是状态为收到信号还是未收到信号。对象状态确定之后,将会一直保持下去,直到有线程调用set或者reset方法。



示例:


namespace 使用ManualResetEvent
{
    class Program
    {

        //当创建ManualResetEvent对象时,构造函数的参数为true,表示已经收到信号。
        //因此当worker线程在threadentry方法中调用waitone时不会被阻塞,而是立即执行后面的语句。

        ManualResetEvent mre = new ManualResetEvent(true);//signaled :收到信号状态
        //如果把构造函数的参数改为false:
            //worker线程将会被阻塞在waitone的位置无法执行,因为它在等待ManualResetEvent对象的状态
            //变为已收到的信号。

        //从这里可以看出,waitone方法在这里和mutex中的用法完全不同,这里是用于信号机制,而mutex中是用于锁机制

            
        static void Main(string[] args)
        {
            Thread.CurrentThread.Name = "main ";
            Program p = new Program();
            Thread worker = new Thread(p.ThreadEntry);
            worker.Name = "worker";
            worker.Start();
            Console.WriteLine("main: finished");
        }
        void ThreadEntry() {
            int i = 0;
            string name = Thread.CurrentThread.Name;
            while (i<10)
            {
                mre.WaitOne();
                Console.WriteLine("{0}:{1}---{2}",name ,i,DateTime .Now.Millisecond);
                i++;              
            }
        
        }


    }
}


使用set和reset方法


示例:


namespace ManualResetEvent的set方法和reset方法
{
    class Program
    {

        ManualResetEvent mre = new ManualResetEvent(false);//未收到信号量

        static void Main(string[] args)
        {
            Thread.CurrentThread.Name = "main ";
            Program p = new Program();
            Thread worker = new Thread(p.ThreadEntry );
            worker.Name = "worker";
            worker.Start();

            p.mre.Set();  //设置为收到信号量
            Console.WriteLine("main:start worker.");
            Thread.Sleep(30);
            p.mre.Reset();  //设置为未收到信号量
            Console.WriteLine("main:stop worker");
            p.mre.Set();   //设置为收到信号量
            Console.WriteLine("main:continue worker");

        }

        void ThreadEntry() {


            int i = 0;
            string name = Thread.CurrentThread.Name;
            while (i<10)
            {
                mre.WaitOne();
                Console.WriteLine("{0}:{1}--{2}",name,i,DateTime .Now.Millisecond);
                Thread.Sleep(10);  //设置sleep,否则循环很快结束,无法实现测试
                i++;

            }
        }
    }
}

  这里通过使用set和reset通过设置信号量状态来控制线程。






目录
相关文章
|
3月前
|
安全 Java
如何停止线程?
【8月更文挑战第8天】如何停止线程?
74 0
|
6月前
|
C#
C# | 使用AutoResetEvent和ManualResetEvent进行线程同步和通信
在多线程编程中,AutoResetEvent 和 ManualResetEvent 是两个常用的同步原语。它们用于线程间的通信和协调,以确保线程按照特定的顺序执行。本篇博客将介绍这两种同步原语的概念、用法和区别。
117 0
C# | 使用AutoResetEvent和ManualResetEvent进行线程同步和通信
|
6月前
线程中断方法详解interrupt
线程中断方法详解interrupt
59 0
|
Java
线程中断方法interrupt、isInterrupted、interrupted方法
线程中断方法interrupt、isInterrupted、interrupted方法
120 0
线程中断方法interrupt、isInterrupted、interrupted方法
|
Java 调度 程序员
线程中断方法interrupt() 与 cancel()
(一).关于interrupt()     interrupt()并不直接中断线程,而是设定一个中断标识,然后由程序进行中断检查,确定是否中断。     1. sleep() & interrupt()    线程A正在使用sleep()暂停着: Thread.
2337 0
线程中断方法interrupt() 与 cancel()
C#深入理解AutoResetEvent和ManualResetEvent
当在C#使用多线程时就免不了使用AutoResetEvent和ManualResetEvent类,可以理解这两个类可以通过设置信号来让线程停下来或让线程重新启动,其实与操作系统里的信号量很相似(汗,考完考试已经有点忘记了)。
1940 0