zoukankan      html  css  js  c++  java
  • 艾伟_转载:WinForm二三事(二) 狼人:

    监视消息循环

    上一篇文章中,我们讨论了消息循环是响应用户输入的根本,还提到了在WinForm中执行耗时操作是因为这个耗时操作与消息循环在同一个UI Thread上,导致不能处理用户的后续响应,造成程序假死。除此之外,还说到了Form中的WndProc方法,说这个方法就是Win32时代那个处理消息的方法的.Net版。

    那么今天这篇文章我们就来编个小程序来模拟一下这个耗时操作,看看是不是如上一篇所说:耗时操作造成消息循环的临时中断不能响应用户后续输入。

    程序很简单,就是一个简单的窗体,上面放置一个按钮,按钮里有一个Thread.Sleep(50*1000)模拟耗时操作:

    public partial class LongTimeForm : Form
    {
        public LongTimeForm()
        {
            InitializeComponent();
            Debug.Listeners.Add(new ConsoleTraceListener());
        }
     
        private void btnLongTime_Click(object sender, EventArgs e)
        {
            Thread.Sleep(50 * 1000);
        }
     
        //既然这个WndProc是Win32中处理消息的方法的.Net版,那么我们应该在这里可以监视到所有用户操作的“消息”
        protected override void WndProc(ref Message m)
        {
            Debug.WriteLine(m.Msg.ToString());
            base.WndProc(ref m);
        }
    }

    WndProc是一个虚方法,我们可以override,那么我们就来看看当用户点击“耗时操作”的按钮后,这个方法是不是还能接收到用户其他的输入呢。

    小技巧
    在开发WinForm程序时,为了方便显示程序的一些操作日志,我们经常将项目属性里的“Windows Application”项目类型修改为“Console Application”,这样在启动程序后,除了会显示窗体外,还会显示一个控制台,在控制台里会显示程序里通过Debug.Write等输出的日志。当产品发布的时候,我们可以将项目属性修改回”Windows Application”。

    启动程序,鼠标在窗体上滑动,后面的控制台上就会显示很多的数字,这些都是消息循环从消息队列里取出的消息(数字是消息的类别,在Windows的一个头文件里定义),然后传递给WndProc方法处理的,控制台上还能输出数字说明现在消息循环还是“流畅的”。当我们点击“耗时操作”按钮后,我们发现,窗体这个时候“死掉了”,不能再接受用户任何的操作,而不管鼠标如何在窗体上滑动、点击,后面的控制台没有一条输出。唔,消息循环阻塞了。Thread.Sleep是50s时间,50s后程序又活过来了,控制台上又有源源不断的输出了。执行耗时操作时,消息循环堵塞

    虽然,我们用实例证明了上一篇所说的东西貌似是正确的,但是难道我们就对这种耗时操作无能为力了么?不啊,我们有多线程啊,我们有异步操作啊。我们就来看看如何使用异步操作来处理这种耗时操作。

    使用委托中的BeginInvoke进行异步操作

    还记得委托的BeginInvoke方法和EndInvoke方法么?今儿我们就用这两个方法来做一个异步的操作(.Net中如果你看到这种BeginXXX和EndXXX成对出现的方法,那说明就是可以进行异步操作了)。

    当你定义一个委托后,编译器会自动的为你生成一个类,还会为你在这个类里提供一个BeginInvoke方法和一个EndInvoke方法,这两个方法的实现是由CLR提供的,而这个BeginInvoke和EndInvoke只是起一个包装的作用。我们还是先来看看将上面的耗时操作修改为异步的代码吧:

    public partial class LongTimeForm : Form
    {
        public LongTimeForm()
        {
            InitializeComponent();
            Debug.Listeners.Add(new ConsoleTraceListener());
        }
     
        private void LongTimeMethod()
        {
            Thread.Sleep(50 * 1000);
        }
     
        private void btnLongTime_Click(object sender, EventArgs e)
        {
            //咱们这儿就不自己定义新的委托了,.Net为我们定义了一串的通用委托使用
            Action longTimeAction = new Action(LongTimeMethod);
            longTimeAction.BeginInvoke(null, null);
        }
        protected override void WndProc(ref Message m)
        {
            Debug.WriteLine(m.Msg.ToString());
            base.WndProc(ref m);
        }
    }

    现在再来运行程序。哇塞,虽然“耗时操作”的按钮点击后,消息循环继续进行,界面也没有假死。嗯,这才是我们要的用户体验(当然,我们应该还给用户一些提示,说耗时操作正在进行,请不要关闭窗口)。

    接下来我们来看看这个异步操作是咋实现的。首先,我们在LongTimeMethod方法里设置断点,点击“耗时操作”按钮后,等待命中断点,断点命中后,选择Visual Studio的“Debug”->”Windows”->”Threads”,这样会打开线程的窗口,在这里我们可以看到类似下图的图片:
    image

    有箭头指示的是正在执行的LongTimeMethod方法的Worker Thread,从这里可以看出Main方法是Main Thread中,看来BeginInvoke就是从Thread Pool中选择一个空闲线程来执行我们的耗时操作。我提到这里是因为经常有人问我:异步和多线程有什么区别?其实,异步是目的,而多线程是实现这个目的的方法。异步是说,A发起一个操作后(一般都是比较耗时的操作,如果不耗时的操作就没有必要异步了),可以继续自顾自的处理它自己的事儿,不用干等着这个耗时操作返回。.Net中的这种异步编程模型,就简化了多线程编程,我们甚至都不用去关心Thread类,就可以做一个异步操作出来。

    去了还要回

    实际上上面演示的耗时操作是“一去不复返”的操作(相当于WCF中的One-Way操作),也就是我发起这个操作后,我就不用管它了,我甚至不关心它运算的结果。但大部分时候我们需要这样的操作:执行完后返回来更新一下UI,比如告诉用户一声我执行完了或者显示执行结果。那这样我们就要考虑异步调用的几种方式了。如果我们要从异步操作里获取结果,我们就得调用EndInvoke方法,那我们又用什么手段来得到异步操作完成的信号呢?因为如果异步操作没有完成,我们就直接调用EndInvoke方法,这样就会阻塞,一直等到异步操作执行完毕后才会执行。

    在继续讨论之前我们来看看BeginInvoke的返回值:

       1: public interface IAsyncResult
       2: {
       3:     object AsyncState { get; }
       4:  
       5:     WaitHandle AsyncWaitHandle { get; }
       6:  
       7:     bool CompletedSynchronously { get; }
       8:  
       9:     bool IsCompleted { get; }
      10: }

    根据BeginInvoke返回的结果,我们就有两种调用异步操作的方式:

    轮询

    IAsyncResult的IsCompleted属性会在异步操作结束后返回true,否则返回false。那么我们就可以用一个循环不断的访问IsCompleted属性,当IsCompleted为true的时候再调用EndInvoke方法:

       1: public partial class LongTimeForm : Form
       2: {
       3:     public LongTimeForm()
       4:     {
       5:         InitializeComponent();
       6:         Debug.Listeners.Add(new ConsoleTraceListener());
       7:     }
       8:  
       9:     private int LongTimeMethod()
      10:     {
      11:         Thread.Sleep(50 * 1000);
      12:         return 10;
      13:     }
      14:  
      15:     private void btnLongTime_Click(object sender, EventArgs e)
      16:     {
      17:         //咱们这儿就不自己定义新的委托了,.Net为我们定义了一串的通用委托使用
      18:         Func<int> longTimeAction = new Func<int>(LongTimeMethod);
      19:         IAsyncResult asynResult = longTimeAction.BeginInvoke(null, null);
      20:  
      21:         //可以做别的事情
      22:         while (!asynResult.IsCompleted)
      23:         { 
      24:             
      25:         }
      26:         int result = longTimeAction.EndInvoke(asynResult);
      27:  
      28:     }
      29:     protected override void WndProc(ref Message m)
      30:     {
      31:         Debug.WriteLine(m.Msg.ToString());
      32:         base.WndProc(ref m);
      33:     }
      34: }

    WaitOne

    在IAsyncResult里还有一个AsyncWaitHandle属性,这是一个WaitHandle类型的属性,这个对象有一个WaitOne方法,还能接受一个超时时间,它会等待这个超时时间指定的长度:

       1: private int LongTimeMethod()
       2: {
       3:     Thread.Sleep(50 * 1000);
       4:     return 10;
       5: }
       6: private void btnLongTime_Click(object sender, EventArgs e)
       7: {
       8:     Func<int> longTimeAction = new Func<int>(LongTimeMethod);
       9:     IAsyncResult asynResult = longTimeAction.BeginInvoke(null, null);
      10:  
      11:     //可以继续处理别的事情
      12:  
      13:     if (asynResult.AsyncWaitHandle.WaitOne(10000, true))
      14:     {
      15:         int result = longTimeAction.EndInvoke(asynResult);
      16:     }
      17: }

    上面的代码的意思就是,异步调用耗时操作后,继续干自己的事儿,然后干完自己的事儿再来等着一个信号,啥信号呢?就是这个耗时操作完成的信号。而且您还别让我等得太久,等久了我就不耐烦了(我可只等待10秒钟啊)。晕死,上面这耗时操作就要执行50秒钟,你就等10秒钟,这不是玩我吗(10秒钟时间过去了,这个WaitOne就不再等待了,线程将继续执行)。

    回调

    其实不管是上面使用轮询的方式还是使用WaitOne等待一个信号量,还是要等待。等待是个让人很恼火的事情。.Net考虑了这一点,为我们准备了回调的方式:你异步调用后继续干你的事儿,等你执行完后,你告我一声就ok了。

       1: private void btnLongTime_Click(object sender, EventArgs e)
       2: {
       3:     Func<int> longTimeAction = new Func<int>(LongTimeMethod);
       4:     //这里使用了一个lambda表达式,省了不少力啊
       5:     IAsyncResult asynResult = longTimeAction.BeginInvoke((result) => {
       6:         int ret = longTimeAction.EndInvoke(result);
       7:     }, null);
       8: }

    当异步操作完成后,上面代码中用lambda表达式表示的一个回调方法就会执行,在这里调用EndInvoke获取耗时操作的结果。在这里想想为什么用lambda,如果不用lambda也不用匿名方法(不管你用啥,实际上就是形成一个闭包)你要怎么做?留作您自己思考。

    更新UI

    上面四种异步调用的方式:一种无声无息,一去不复返。一种轮询、一种等待,外加一个回调。实际上耗时操作的结果都让代码给“吃”了。一般情况下,我们处理完耗时操作总要有所表现吧,比如更新一下UI等等。那我们就来看看如何更新UI。

    当你运行这个程序时,当耗时操作结束后,啪嚓一下,程序出异常了:

    callcontrolfromotherthread

    啊?为什么啊,为什么就不行啊。还不能从不是创建这个控件的线程中访问这个控件。那怎么办?看来我们的异步操作还得改进改进啊。

    (未完待续)

  • 相关阅读:
    Servlet的PrintWriter out = response.getWriter()使用
    Java Performance Optimization Tools and Techniques for Turbocharged Apps--reference
    Scrum介绍——续
    Scrum介绍
    CMM能力成熟度模型
    自定义Spark Partitioner提升es-hadoop Bulk效率——续
    $digest already in progress 解决办法——续
    $digest already in progress 解决办法
    linux tcpdump 抓包
    Asterisk——part 1
  • 原文地址:https://www.cnblogs.com/waw/p/2157046.html
Copyright © 2011-2022 走看看