zoukankan      html  css  js  c++  java
  • 多线程通中的AutoResetEvent与ManualResetEvent

    AutoResetEvent 允许线程通过发信号互相通信。通常,此通信涉及线程需要独占访问的资源。

      线程通过调用 AutoResetEvent 上的 WaitOne 来等待信号。如果 AutoResetEvent 处于非终止状态,则该线程阻塞,并等待当前控制资源的线程通过调用 Set 发出资源可用的信号。

      调用 SetAutoResetEvent 发信号以释放等待线程。AutoResetEvent 将保持终止状态,直到一个正在等待的线程被释放,然后自动返回非终止状态。如果没有任何线程在等待,则状态将无限期地保持为终止状态。

      可以通过将一个布尔值传递给构造函数来控制 AutoResetEvent 的初始状态,如果初始状态为终止状态,则为 true;否则为false

      通俗的来讲只有等myResetEven.Set()成功运行后,myResetEven.WaitOne()才能够获得运行机会;Set是发信号,WaitOne是等待信号,只有发了信号,等待的才会执行。如果不发的话,WaitOne后面的程序就永远不会执行。下面我们来举一个例子:我去书店买书,当我选中一本书后我会去收费处付钱,付好钱后再去仓库取书。这个顺序不能颠倒,我作为主线程,收费处和仓库做两个辅助线程,代码如下

    using System;

    using System.Linq;

    //using System.Activities;

    //using System.Activities.Statements;

    using System.Threading;

     

    namespace CaryAREDemo

    {

        class Me

        {

            const int numIterations = 50;

     

             

            static AutoResetEvent PayMoneyEvent = new AutoResetEvent(false);

            static AutoResetEvent GetBookEvent  = new AutoResetEvent(false);

     

            // static ManualResetEvent PayMoneyEvent = new ManualResetEvent(false);  //初始化为非终止状态 

            // static ManualResetEvent GetBookEvent  = new ManualResetEvent(false);  //初始化为非终止状态

     

            static int number;         //这是关键资源

     

            static void Main()

            {

                Thread payMoneyThread = new Thread(new ThreadStart(PayMoneyProc));

                payMoneyThread.Name = "付钱线程";

     

                Thread getBookThread = new Thread(new ThreadStart(GetBookProc));

                getBookThread.Name  = "取书线程";

     

                payMoneyThread.Start();

                getBookThread.Start();

     

                for (int i = 1; i <= numIterations; i++)

                {

                    Console.WriteLine("买书线程:数量{0}", i);

                    number = i;

                    //Signal that a value has been written.

     

                    PayMoneyEvent.Set();

                    Thread.Sleep(1);     //保证每次PayMoneyEvent.Set()释放当前资源时PayMoneyProc线程都有足够的时间捕获并且运行 

                    GetBookEvent.Set();

                    Thread.Sleep(1);     //保证每次GetBookEvent.Set()释放当前资源时GetBookProc线程都有足够的时间捕获并且运行

                 }

                payMoneyThread.Abort();

                getBookThread.Abort();

            }

     

            static void PayMoneyProc()      //付钱线程

            {

                while (true)

                {

                    PayMoneyEvent.WaitOne();

                    //PayMoneyEvent.Reset();  //如果是ManualResetEvent 就需要手动的设置 reset()

                    Console.WriteLine("{0}:数量{1}", Thread.CurrentThread.Name, number);

                }

            }

     

            static void GetBookProc()       //取书线程

            {

                while (true)

                {

                    GetBookEvent.WaitOne();

                    // GetBookEvent.Reset();              

                    Console.WriteLine("{0}:数量{1}", Thread.CurrentThread.Name, number);

                    Console.WriteLine("------------------------------------------");

                    Thread.Sleep(0);

                }

            }

        }

    }

     

    结    果:

    买书线程:数量1
    付钱线程:数量1
    取书线程:数量1
    ------------------------------------------
    买书线程:数量2
    付钱线程:数量2
    取书线程:数量2
    ------------------------------------------
    买书线程:数量3
    付钱线程:数量3
    取书线程:数量3
    ------------------------------------------
    买书线程:数量4
    付钱线程:数量4
    取书线程:数量4
    ------------------------------------------
    买书线程:数量5
    付钱线程:数量5
    取书线程:数量5
    ------------------------------------------
    买书线程:数量6
    付钱线程:数量6
    取书线程:数量6

    ...............

    程序总结:Set方法是使 WaitOne 有信号,也就是说 可以执行 WaitOne 下面的语句。

    Reset() 方法是使 WaitOne 无信号,也就是说 在WaitOne 处处于等待状态,WaitOne下面的语句执行不了.

    使并发的线程有顺序,需要调用 Sleep(n), n >0 ,

    Set()将事件状态设置为终止状态,最多允许一个等待线程继续, 意思是终止等待,WaitOne获取信号,WaitOne下面的代码可以执行到。

    Reset() 将事件状态设置为非终止状态,导致(WaitOne 以后的)线程阻止

    AutoResetEvent与ManualResetEvent的区别:

      他们的用法/声明都很类似,Set方法将信号置为发送状态 Reset方法将信号置为不发送状态WaitOne等待信号的发送。其实,从名字就可以看出一个手动,一个自动,这个手动和自动实际指的是在Reset方法的处理上,如下面例子:

    public AutoResetEvent autoevent = new AutoResetEvent(true);
    public ManualResetEvent manualevent = new ManualResetEvent(true);

    autoevent.WaitOne();      //默认信号都处于发送状态,
    manualevent.WaitOne();

      如果 某个线程调用上面该方法,则当信号处于发送状态时,该线程会得到信号,得以继续执行。差别就在调用后,autoevent.WaitOne()每次只允许一个线程进入,当某个线程得到信号(也就是有其他线程调用了autoevent.Set()方法后)后,autoevent会自动又将信号置为不发送状态,则其他调用WaitOne的线程只有继续等待.也就是说,autoevent一次只唤醒一个线程。而manualevent则可以唤醒多个线程,因为当某个线程调用了set方法后,其他调用waitone的线程获得信号得以继续执行,而manualevent不会自动将信号置为不发送.也就是说,除非手工调用了manualevent.Reset().方法,则manualevent将一直保持有信号状态,manualevent也就可以同时唤醒多个线程继续执行。如果上面的程序换成ManualResetEvent的话,就需要在waitone后面做下reset。

    转自herryz的专栏

    http://blog.csdn.net/herryz/article/details/5956657 

  • 相关阅读:
    Codeforces Beta Round #18 (Div. 2 Only) C. Stripe 前缀和
    Codeforces Round #309 (Div. 1) C. Love Triangles dfs
    Codeforces Round #309 (Div. 1) B. Kyoya and Permutation 构造
    Codeforces Round #309 (Div. 2) C. Kyoya and Colored Balls 排列组合
    Codeforces Round #309 (Div. 2) B. Ohana Cleans Up 字符串水题
    Codeforces Round #309 (Div. 2) A. Kyoya and Photobooks 字符串水题
    Codeforces Beta Round #13 E. Holes 分块暴力
    Codeforces Beta Round #12 (Div 2 Only) D. Ball sort/map
    Codeforces Beta Round #6 (Div. 2 Only) E. Exposition multiset
    Codeforces Beta Round #5 E. Bindian Signalizing 并查集
  • 原文地址:https://www.cnblogs.com/zhxm/p/2642302.html
Copyright © 2011-2022 走看看