码迷,mamicode.com
首页 > 其他好文 > 详细

AutoResetEvent的用法

时间:2014-11-05 18:49:11      阅读:252      评论:0      收藏:0      [点我收藏+]

标签:style   blog   http   io   color   ar   os   for   sp   

最近在接触了一个SL的项目,真是烦人,感觉与WPF的区别还是蛮大的,一些控件还有基本的XAML标记都不一样.真让人纠结,真希望赶紧结束这个SL的项目,还是做WPF顺手.

今天做SL碰到的问题是SL异步调用WCF的问题,SL调用WCF默认是异步的,但是很多时候是需要同步调用,例如用户登录操作,这就让人蛋疼了,怎么把异步搞成同步呢.在网上查了一些资料以后发现需要AutoResetEvent类,这个类在MSDN上的解释是:通知正在等待的线程已发生事件  , 这句话我看了半天都没太明白是什么意思,和朋友 讨论了一下才明白.我朋友是做Unix、Linux开发的,所以说的原理不知道是不适合Window系统.

  第一步 : 可能需要调用一个底层的接口或者什么的来阻塞应用程序的主线程

   第二部 : (经过N秒以后)通过另一个线程发送Window消息或者其他的机制来对这个应用程序解锁,使其继续执行

 

有了上面的理解以后就可以明白 “通知正在等待的线程已发生事件”这句话的意思了,首先AutoResetEvent会通过WaitOne方法来阻塞一个线程,而用Set方法去解锁这个阻塞,一边允许后面的一个或者多个线程执行

MSDN上的实例:

 

class Program
   {
       const int numIterations = 10;   //在这里我改成了10次

       static AutoResetEvent myResetEvent = new AutoResetEvent(false);
       static int number;

       static void Main(string[] args)
       {
           Thread myReaderThread = new Thread(new ThreadStart(MyReaderThreadPro));
           myReaderThread.Name = "ReaderThread";
           myReaderThread.Start();

           for (int i = 1; i <= numIterations; i++)
           {
               Console.WriteLine("number的值为 : {0}", i);
               number = i;
               //将事件状态设为终止状态,允许一个或多个等待线程继续
           //在这里发送信号,使myReaderThread这个线程继续执行
            myResetEvent.Set();
               Thread.Sleep(0);
           }
       }

       static void MyReaderThreadPro()
       {
           while (true)
           {
               //阻塞当前线程,直到收到信号
            myResetEvent.WaitOne();
               Console.WriteLine("线程 : {0} 读取到的值为 : {1}",Thread.CurrentThread.Name,number);
           }
       }
   }
结果如图:
bubuko.com,布布扣
 
注: 程序逻辑可确保 ThreadProc 方法永远不会两次读取同一个值。它并不确保 ThreadProc 方法将读取由 Main 写入的每一个值。
    要确保这一点,则要求具有第二个 AutoResetEvent 锁定。

从另一个文章看到

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 = 550;
        static AutoResetEvent myResetEvent = new AutoResetEvent(false);
        static AutoResetEvent ChangeEvent = new AutoResetEvent(false);
        //static ManualResetEvent myResetEvent = new ManualResetEvent(false);
        //static ManualResetEvent ChangeEvent = 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.
                myResetEvent.Set();
                ChangeEvent.Set();
                Thread.Sleep(0);
            }
            payMoneyThread.Abort();
            getBookThread.Abort();
        }

        static void PayMoneyProc()
        {
            while (true)
            {
                myResetEvent.WaitOne();
                //myResetEvent.Reset();
                Console.WriteLine("{0}:数量{1}", Thread.CurrentThread.Name, number);
            }
        }
        static void GetBookProc()
        {
            while (true)
            {
                ChangeEvent.WaitOne();
                // ChangeEvent.Reset();               
                Console.WriteLine("{0}:数量{1}", Thread.CurrentThread.Name, number);
                Console.WriteLine("------------------------------------------");
                Thread.Sleep(0);
            }
        }
    }
}
运行结果如下:
bubuko.com,布布扣

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。

AutoResetEvent的用法

标签:style   blog   http   io   color   ar   os   for   sp   

原文地址:http://www.cnblogs.com/xiaoheibupahei/p/4076688.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!