zoukankan      html  css  js  c++  java
  • 走进异步编程的世界

    转载:https://www.cnblogs.com/liqingwen/p/5877042.html

    走进异步编程的世界 - 在 GUI 中执行异步操作

    【博主】反骨仔  【原文地址】http://www.cnblogs.com/liqingwen/p/5877042.html 

       这是继《开始接触 async/await 异步编程》、《走进异步编程的世界 - 剖析异步方法》后的第三篇。主要介绍在 WinForm 中如何执行异步操作。

    目录

    一、在 WinForm 程序中执行异步操作

      下面通过窗体示例演示以下操作-点击按钮后:

        ①将按钮禁用,并将标签内容改成:“Doing”(表示执行中);

        ②线程挂起3秒(模拟耗时操作);

        ③启用按钮,将标签内容改为:“Complete”(表示执行完成)。

    复制代码
     1     public partial class Form1 : Form
     2     {
     3         public Form1()
     4         {
     5             InitializeComponent();
     6         }
     7 
     8         private void btnDo_Click(object sender, EventArgs e)
     9         {
    10             btnDo.Enabled = false;
    11             lblText.Text = @"Doing";
    12 
    13             Thread.Sleep(3000);
    14 
    15             btnDo.Enabled = true;
    16             lblText.Text = @"Complete";
    17         }
    18     }
    复制代码

      可是执行结果却是:

    图1-1

      【发现的问题】

        ①好像没有变成“Doing”?

        ②并且拖动窗口的时候卡住不动了?

        ③3秒后突然变到想拖动到的位置?

        ④同时文本变成“Complete”?

      【分析】GUI 程序在设计中要求所有的显示变化都必须在主 GUI 线程中完成,如点击事件和移动窗体。Windows 程序时通过 消息来实现,消息放入消息泵管理的消息队列中。点击按钮时,按钮的Click消息放入消息队列。消息泵从队列中移除该消息,并开始处理点击事件的代码,即 btnDo_Click 事件的代码。

      btnDo_Click 事件会将触发行为的消息放入队列,但在 btnDo_Click 时间处理程序完全退出前(线程挂起 3 秒退出前),消息都无法执行。(3 秒后)接着所有行为都发生了,但速度太快肉眼无法分辨才没有发现标签改成“Doing”。

    图1-2 点击事件

    图1-3 点击事件具体执行过程

      

      现在我们加入 async/await 特性。

    复制代码
     1     public partial class Form1 : Form
     2     {
     3         public Form1()
     4         {
     5             InitializeComponent();
     6         }
     7 
     8         private async void btnDo_Click(object sender, EventArgs e)
     9         {
    10             btnDo.Enabled = false;
    11             lblText.Text = @"Doing";
    12 
    13             await Task.Delay(3000);
    14 
    15             btnDo.Enabled = true;
    16             lblText.Text = @"Complete";
    17         }
    18     }
    复制代码

    图1-4

      现在,就是原先希望看到的效果。

      【分析】btnDo_Click 事件处理程序先将前两条消息压入队列,然后将自己从处理器移出,在3秒后(等待空闲任务完成后 Task.Delay )再将自己压入队列。这样可以保持响应,并保证所有的消息可以在线程挂起的时间内被处理。

     1.1 Task.Yield

      Task.Yield 方法创建一个立刻返回的 awaitable。等待一个Yield可以让异步方法在执行后续部分的同时返回到调用方法。可以将其理解为 离开当前消息队列,回到队列末尾,让 CPU 有时间处理其它任务。

    复制代码
     1     class Program
     2     {
     3         static void Main(string[] args)
     4         {
     5             const int num = 1000000;
     6             var t = DoStuff.Yield1000(num);
     7 
     8             Loop(num / 10);
     9             Loop(num / 10);
    10             Loop(num / 10);
    11 
    12             Console.WriteLine($"Sum: {t.Result}");
    13 
    14             Console.Read();
    15         }
    16 
    17         /// <summary>
    18         /// 循环
    19         /// </summary>
    20         /// <param name="num"></param>
    21         private static void Loop(int num)
    22         {
    23             for (var i = 0; i < num; i++) ;
    24         }
    25     }
    26 
    27     internal static class DoStuff
    28     {
    29         public static async Task<int> Yield1000(int n)
    30         {
    31             var sum = 0;
    32             for (int i = 0; i < n; i++)
    33             {
    34                 sum += i;
    35                 if (i % 1000 == 0)
    36                 {
    37                     await Task.Yield(); //创建异步产生当前上下文的等待任务
    38                 }
    39             }
    40 
    41             return sum;
    42         }
    43     }
    复制代码

     图1.1-1

      上述代码每执行1000次循环就调用 Task.Yield 方法创建一个等待任务,让处理器有时间处理其它任务。该方法在 GUI 程序中是比较有用的。

    二、在 WinForm 中使用异步 Lambda 表达式

      将刚才的窗口程序的点击事件稍微改动一下。

    复制代码
     1     public partial class Form1 : Form
     2     {
     3         public Form1()
     4         {
     5             InitializeComponent();
     6 
     7             //async (sender, e) 异步表达式
     8             btnDo.Click += async (sender, e) =>
     9             {
    10                 Do(false, "Doing");
    11 
    12                 await Task.Delay(3000);
    13 
    14                 Do(true, "Finished");
    15             };
    16         }
    17 
    18         private void Do(bool isEnable, string text)
    19         {
    20             btnDo.Enabled = isEnable;
    21             lblText.Text = text;
    22         }
    23     }
    复制代码

      还是原来的配方,还是熟悉的味道,还是原来哪个窗口,变的只是内涵。

    图2-1

    三、一个完整的 WinForm 程序

      现在在原来的基础上添加了进度条,以及取消按钮。

    复制代码
     1     public partial class Form1 : Form
     2     {
     3         private CancellationTokenSource _source;
     4         private CancellationToken _token;
     5 
     6         public Form1()
     7         {
     8             InitializeComponent();
     9         }
    10 
    11         /// <summary>
    12         /// Do 按钮事件
    13         /// </summary>
    14         /// <param name="sender"></param>
    15         /// <param name="e"></param>
    16         private async void btnDo_Click(object sender, EventArgs e)
    17         {
    18             btnDo.Enabled = false;
    19 
    20             _source = new CancellationTokenSource();
    21             _token = _source.Token;
    22 
    23             var completedPercent = 0; //完成百分比
    24             const int time = 10; //循环次数
    25             const int timePercent = 100 / time; //进度条每次增加的进度值
    26 
    27             for (var i = 0; i < time; i++)
    28             {
    29                 if (_token.IsCancellationRequested)
    30                 {
    31                     break;
    32                 }
    33 
    34                 try
    35                 {
    36                     await Task.Delay(500, _token);
    37                     completedPercent = (i + 1) * timePercent;
    38                 }
    39                 catch (Exception)
    40                 {
    41                     completedPercent = i * timePercent;
    42                 }
    43                 finally
    44                 {
    45                     progressBar.Value = completedPercent;
    46                 }
    47             }
    48 
    49             var msg = _token.IsCancellationRequested ? $"进度为:{completedPercent}% 已被取消!" : $"已经完成";
    50 
    51             MessageBox.Show(msg, @"信息");
    52 
    53             progressBar.Value = 0;
    54             InitTool();
    55         }
    56 
    57         /// <summary>
    58         /// 初始化窗体的工具控件
    59         /// </summary>
    60         private void InitTool()
    61         {
    62             progressBar.Value = 0;
    63             btnDo.Enabled = true;
    64             btnCancel.Enabled = true;
    65         }
    66 
    67         /// <summary>
    68         /// 取消事件
    69         /// </summary>
    70         /// <param name="sender"></param>
    71         /// <param name="e"></param>
    72         private void btnCancel_Click(object sender, EventArgs e)
    73         {
    74             if (btnDo.Enabled) return;
    75 
    76             btnCancel.Enabled = false;
    77             _source.Cancel();
    78         }
    79     }
    复制代码

     图3-1

    四、另一种异步方式 - BackgroundWorker 类

      与 async/await 不同的是,你有时候可能需要一个额外的线程,在后台持续完成某项任务,并不时与主线程通信,这时就需要用到 BackgroundWorker 类。主要用于 GUI 程序。

      书中的千言万语不及一个简单的示例。

    复制代码
     1     public partial class Form2 : Form
     2     {
     3         private readonly BackgroundWorker _worker = new BackgroundWorker();
     4 
     5         public Form2()
     6         {
     7             InitializeComponent();
     8 
     9             //设置 BackgroundWorker 属性
    10             _worker.WorkerReportsProgress = true;   //能否报告进度更新
    11             _worker.WorkerSupportsCancellation = true;  //是否支持异步取消
    12 
    13             //连接 BackgroundWorker 对象的处理程序
    14             _worker.DoWork += _worker_DoWork;   //开始执行后台操作时触发,即调用 BackgroundWorker.RunWorkerAsync 时触发
    15             _worker.ProgressChanged += _worker_ProgressChanged; //调用 BackgroundWorker.ReportProgress(System.Int32) 时触发
    16             _worker.RunWorkerCompleted += _worker_RunWorkerCompleted;   //当后台操作已完成、被取消或引发异常时触发
    17         }
    18 
    19         /// <summary>
    20         /// 当后台操作已完成、被取消或引发异常时发生
    21         /// </summary>
    22         /// <param name="sender"></param>
    23         /// <param name="e"></param>
    24         private void _worker_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e)
    25         {
    26             MessageBox.Show(e.Cancelled ? $@"进程已被取消:{progressBar.Value}%" : $@"进程执行完成:{progressBar.Value}%");
    27             progressBar.Value = 0;
    28         }
    29 
    30         /// <summary>
    31         /// 调用 BackgroundWorker.ReportProgress(System.Int32) 时发生
    32         /// </summary>
    33         /// <param name="sender"></param>
    34         /// <param name="e"></param>
    35         private void _worker_ProgressChanged(object sender, ProgressChangedEventArgs e)
    36         {
    37             progressBar.Value = e.ProgressPercentage;   //异步任务的进度百分比
    38         }
    39 
    40         /// <summary>
    41         /// 开始执行后台操作触发,即调用 BackgroundWorker.RunWorkerAsync 时发生
    42         /// </summary>
    43         /// <param name="sender"></param>
    44         /// <param name="e"></param>
    45         private static void _worker_DoWork(object sender, DoWorkEventArgs e)
    46         {
    47             var worker = sender as BackgroundWorker;
    48             if (worker == null)
    49             {
    50                 return;
    51             }
    52 
    53             for (var i = 0; i < 10; i++)
    54             {
    55                 //判断程序是否已请求取消后台操作
    56                 if (worker.CancellationPending)
    57                 {
    58                     e.Cancel = true;
    59                     break;
    60                 }
    61 
    62                 worker.ReportProgress((i + 1) * 10);    //触发 BackgroundWorker.ProgressChanged 事件
    63                 Thread.Sleep(250);  //线程挂起 250 毫秒
    64             }
    65         }
    66 
    67         private void btnDo_Click(object sender, EventArgs e)
    68         {
    69             //判断 BackgroundWorker 是否正在执行异步操作
    70             if (!_worker.IsBusy)
    71             {
    72                 _worker.RunWorkerAsync();   //开始执行后台操作
    73             }
    74         }
    75 
    76         private void btnCancel_Click(object sender, EventArgs e)
    77         {
    78             _worker.CancelAsync();  //请求取消挂起的后台操作
    79         }
    80     }
    复制代码

    图4-1

     传送门

      入门:《走进异步编程的世界 - 开始接触 async/await 异步编程

      上篇:《走进异步编程的世界 - 剖析异步方法(上)》《走进异步编程的世界 - 剖析异步方法(下)

  • 相关阅读:
    集群、分布式与微服务概念和区别理解
    博弈论的入门——nim游戏&&sg函数浅谈
    csp-2020 初赛游记
    洛谷 P2340 [USACO03FALL]Cow Exhibition G 题解
    P5687 [CSP-SJX2019]网格图 题解
    HBase 数据迁移/备份方法
    mac远程连接服务上传下载命令实例
    Redis安装详细步骤
    VMware虚拟机中的CentOS服务安装Nginx后本机无法访问的解决办法
    开发业务逻辑处理之策略模式场景使用
  • 原文地址:https://www.cnblogs.com/Jeely/p/11712425.html
Copyright © 2011-2022 走看看