在Winform開發中,使用Async-Awati非同步任務處理代替BackgroundWorker

来源:https://www.cnblogs.com/wuhuacong/archive/2022/06/14/16374158.html
-Advertisement-
Play Games

在Winform開發中有時候我們為了不影響主UI線程的處理,以前我們使用後臺線程BackgroundWorker來處理一些任務操作,不過隨著非同步處理提供的便利性,我們可以使用Async-Awati非同步任務處理替換原來的後臺線程BackgroundWorker處理方式,更加的簡潔明瞭。 ...


在Winform開發中有時候我們為了不影響主UI線程的處理,以前我們使用後臺線程BackgroundWorker來處理一些任務操作,不過隨著非同步處理提供的便利性,我們可以使用Async-Awati非同步任務處理替換原來的後臺線程BackgroundWorker處理方式,更加的簡潔明瞭。

在一些耗時的操作過程中,在長時間運行時可能會導致用戶界面 (UI) 處於停止響應狀態,因此使用使用Async-Awati非同步任務處理或者後臺線程BackgroundWorker來處理一些任務操作很有必要。

在使用BackgroundWorker的過程中,我們可以定義自己的狀態參數信息,從而實現線程狀態的實時跟蹤以及進度和信息提示,方便我們及時通知UI進行更新。

現在使用Async-Awati非同步任務處理,一樣可以在處理過程中通知UI更新進度和提示信息。

1、回顧BackgroundWorker後臺線程的處理代碼

我們先來瞭解一下BackgroundWorker後臺線程的操作代碼,對比下再介紹使用Async-Awati非同步任務處理和通知操作。

一般的使用代碼是需要初始化後臺線程對象的,如下代碼所示。

    public partial class MainFrame : BaseForm
    {
        /// <summary>
        /// 增加一個變數來記錄線程狀態
        /// </summary>
        private bool IsThreadRunning = false;
        private BackgroundWorker worker = new BackgroundWorker();

        public MainFrame()
        {
            InitializeComponent();

            Portal.gc.InitData();

            worker.WorkerSupportsCancellation = true;   //支持取消
            worker.WorkerReportsProgress = true;        //支持報告進度
            worker.DoWork += worker_DoWork;             //處理過程
            worker.RunWorkerCompleted += worker_RunWorkerCompleted; //完成操作
            worker.ProgressChanged += worker_ProgressChanged;       //報告進度
        }

例如進度條的通知,主要就是計算總任務的數量,並用於顯示當前的任務進度信息,實例代碼如下所示

        /// <summary>
        /// 進度條的通知
        /// </summary>
        void worker_ProgressChanged(object sender, ProgressChangedEventArgs e)
        {
            this.barProgress.EditValue = e.ProgressPercentage;
            CollectStateInfo stateInfo = e.UserState as CollectStateInfo;
            if (stateInfo != null)
            {
                var message = string.Format("正在採集 {0} 的 {1} , 項目名稱為:{2}", stateInfo.TotalRecords, stateInfo.CompletedRecord + 1, stateInfo.CurrentItemName);
                this.lblTips.Text = message;
                this.barTips.Caption = message;

                //記錄運行位置
                JobParameterHelper.SaveData(new CurrentJobParameter(stateInfo));
            }
        }

後臺進程處理的關鍵事件就是處理過程的代碼實現,它處理任務的時候,把當前的狀態通過事件方式通知UI顯示。

        private void backgroundWorker1_DoWork(object sender, DoWorkEventArgs e)
        {
            BackgroundWorker worker = sender as BackgroundWorker;
            Random r = new Random();
            int numCount = 0;
            while (worker.CancellationPending == false)
            {
                int num = r.Next(0, 10000);
                if (num % 5 == 0)
                {
                    numCount++;
                    worker.ReportProgress(0, num);
                    Thread.Sleep(1000);
                }
            }
            e.Result = numCount;
        }

觸發任務開始的時候,我們調用代碼如下所示。

    if (!worker.IsBusy)
    {
        worker.RunWorkerAsync(stateInfo);
    }

任務完成後,通知更新界面即可。

void worker_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e)
{
    //還原按鈕狀態
    InitCollectState();
    IsThreadRunning = false;

    string message = "採集操作完成";
    MessageDxUtil.ShowTips(message);
}

 

2、使用Async-Awati非同步任務處理代替BackgroundWorker

為了測試使用Asyn-Await非同步處理,我創建一個簡單的Demo程式,用於測試其效果。

 窗體裡面放置一個按鈕,觸發按鈕執行任務操作,並逐步提示進度條信息,完成後提示任務完成。

 為了在非同步處理中提示進度信息,我們引入了Progress 線程通知對象。

定義一個線程通知的Progress對象,如下所示。這裡的int也可以換為自定義的對象類,以方便承載更多的信息。

  var reporter = new Progress<int>(progressChanged);

其中progressChanged 是我們定義的一個通知UI顯示進度的處理函數,如下所示。

        /// <summary>
        /// 報告進度
        /// </summary>
        /// <param name="percentage">當前進度</param>
        void progressChanged(int percentage)
        {
            this.progressBar1.EditValue = percentage;

            this.progressPanel.Caption = percentage == 100 ? "任務已完成": "任務正在處理";
            this.progressPanel.Description = String.Format("完成【{0}%】", percentage);
        }

接著我們定義一個處理任務的WorkStart方法,接收一個Progress對象,如下代碼所示。

      var reporter = new Progress<int>(progressChanged);
      var result = await this.WorkStart(reporter);

為了簡單樣式非同步調用,我們這裡只是延遲了一下處理任務,實際處理的話,調用非同步方法即可。

        /// <summary>
        /// 執行任務
        /// </summary>
        private async Task<CommonResult> WorkStart(IProgress<int> progress)
        {
            var result = new CommonResult();
            for(int i = 0; i < 100; i++)
            {
                await Task.Delay(100);
                progress.Report(i + 1);
            }
            result.Success = true;

            return result;
        }

我們可以看到,任務每次執行到一個節點,就會調用對象方法Report進行通知處理。

而任務完成後,我們簡單的通知處理即可。整段代碼如下所示。

    /// <summary>
    /// Async Await非同步線程處理
    /// </summary>
    public partial class FrmAsyncAwaitDemo : DevExpress.XtraEditors.XtraForm
    {
        public FrmAsyncAwaitDemo()
        {
            InitializeComponent();


            this.progressBar1.Visible = false;
            this.progressPanel.Visible = false;
        }

        private async void btnStart_Click(object sender, EventArgs e)
        {
            this.btnStart.Enabled = false;
            this.progressBar1.Visible = true;
            this.progressPanel.Visible = true;

            var reporter = new Progress<int>(progressChanged);
            var result = await this.WorkStart(reporter);
            this.WorkCompleted(result);
        }


        /// <summary>
        /// 任務完成
        /// </summary>
        /// <param name="result">返回結果CommonResult</param>
        void WorkCompleted(CommonResult result)
        {
            if (result.Success)
            {
                //操作成功的處理
            }

            var alert = new AlertControl();
            alert.FormLocation = AlertFormLocation.TopRight;
            alert.AutoFormDelay = 2000;
            alert.Show(this, "任務提示", result.Success ? "任務處理完成,操作成功" : result.ErrorMessage);

            this.progressBar1.Visible = false;
            this.progressPanel.Visible = false;
            this.btnStart.Enabled = true;
        }

        /// <summary>
        /// 報告進度
        /// </summary>
        /// <param name="percentage">當前進度</param>
        void progressChanged(int percentage)
        {
            this.progressBar1.EditValue = percentage;

            this.progressPanel.Caption = percentage == 100 ? "任務已完成": "任務正在處理";
            this.progressPanel.Description = String.Format("完成【{0}%】", percentage);
        }

        /// <summary>
        /// 執行任務
        /// </summary>
        private async Task<CommonResult> WorkStart(IProgress<int> progress)
        {
            var result = new CommonResult();
            for(int i = 0; i < 100; i++)
            {
                await Task.Delay(100);
                progress.Report(i + 1);
            }
            result.Success = true;

            return result;
        }
    }

在我們實際的案例中,文件上傳處理就使用了這種方式來通知UI線程,任務處理的代碼如下所示。

 因此使用Async-Awati非同步任務處理代替BackgroundWorker,代碼更加簡便,而且使用 IProgress介面類來處理通知,也是非常方便的。

 

專註於代碼生成工具、.Net/.NetCore 框架架構及軟體開發,以及各種Vue.js的前端技術應用。著有Winform開發框架/混合式開發框架、微信開發框架、Bootstrap開發框架、ABP開發框架、SqlSugar開發框架等框架產品。
  轉載請註明出處:撰寫人:伍華聰  http://www.iqidi.com 
    

您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 前言 最近有沒有想要買股票和基金的小伙伴,今天我要教大家一個神奇的東西,如何去計算平均值。沒有人不喜歡錢吧… 用Python繪製出股價的5日均線和20日均線。眾所周知,5日均線是短線交易的生死線,而20日均線是中長線趨勢的分水嶺。因此,基於這兩 條均線,可以設計出一些簡單的交易策略。 下麵是我練習的 ...
  • 1、無限極往上獲取平臺類目樹信息 數據結構:商品類目id《category_id,商品類目父id《parent_id 數據需求:根據傳入最低層類目id,獲取所有上級類目信息(包含自己) 代碼如下: 1 // 無限極往上獲取平臺類目樹信息 2 public function platformCateg ...
  • 1.前言 冬天很冷,買了一個鍋爐,需要迴圈泵的。簡單來說就是鍋爐水熱了之後迴圈泵自動開啟,然後將熱水輸送走,送到暖 氣,熱水抽走,涼水進入鍋爐,溫度降低,迴圈泵關閉,等待下一次水燒熱。因為需要取暖的房子距離燒鍋爐的地方比較遠,所以需要迴圈 泵,如果距離近的話水燒熱後利用熱水上流冷水迴流的原理會自動完 ...
  • 我們經常需要統計一個方法的耗時,一般我們會這樣做: public class Test { public static void main(String[] args) throws InterruptedException { long start = System.currentTimeMill ...
  • 我本地寫了一個rabbitmq fanout模式的demo。consumer啟動類和producer啟動類都放到了一個springboot程式里。本地調試通過。 突然有個疑問,springboot項目是怎麼來發現主啟動類的呢? 我們知道,預設使用maven打包時,是個普通的可供依賴的jar包,僅包含 ...
  • referer,正確寫法referrer,指的是網站的一種安全策略,在請求頭CSP(Content-Security-Policy),標簽或者是指定的html標簽里都可以設置它,它指的是上一個請求的來源記錄,比如你從a1通過鏈連,跳到a2,那在a2的請求頭裡,就會有a1的網址或者功能變數名稱,這個和refe ...
  • 項目中經常遇到CSV文件的讀寫需求,其中的難點主要是CSV文件的解析。本文會介紹CsvHelper、TextFieldParser、正則表達式三種解析CSV文件的方法,順帶也會介紹一下CSV文件的寫方法。 CSV文件標準 在介紹CSV文件的讀寫方法前,我們需要瞭解一下CSV文件的格式。 文件示例 一 ...
  • 這幾天在看 C++ 的 lambda 表達式,挺有意思,這個標準是在 C11標準 加進去的,也就是 2011 年,相比 C# 2007 還晚了個 4 年, Lambda 這東西非常好用,會上癮,今天我們簡單聊一聊。 一:語法定義 首先我們看下 C++ 語法定義格式: [capture] (param ...
一周排行
    -Advertisement-
    Play Games
  • Dapr Outbox 是1.12中的功能。 本文只介紹Dapr Outbox 執行流程,Dapr Outbox基本用法請閱讀官方文檔 。本文中appID=order-processor,topic=orders 本文前提知識:熟悉Dapr狀態管理、Dapr發佈訂閱和Outbox 模式。 Outbo ...
  • 引言 在前幾章我們深度講解了單元測試和集成測試的基礎知識,這一章我們來講解一下代碼覆蓋率,代碼覆蓋率是單元測試運行的度量值,覆蓋率通常以百分比表示,用於衡量代碼被測試覆蓋的程度,幫助開發人員評估測試用例的質量和代碼的健壯性。常見的覆蓋率包括語句覆蓋率(Line Coverage)、分支覆蓋率(Bra ...
  • 前言 本文介紹瞭如何使用S7.NET庫實現對西門子PLC DB塊數據的讀寫,記錄了使用電腦模擬,模擬PLC,自至完成測試的詳細流程,並重點介紹了在這個過程中的易錯點,供參考。 用到的軟體: 1.Windows環境下鏈路層網路訪問的行業標準工具(WinPcap_4_1_3.exe)下載鏈接:http ...
  • 從依賴倒置原則(Dependency Inversion Principle, DIP)到控制反轉(Inversion of Control, IoC)再到依賴註入(Dependency Injection, DI)的演進過程,我們可以理解為一種逐步抽象和解耦的設計思想。這種思想在C#等面向對象的編 ...
  • 關於Python中的私有屬性和私有方法 Python對於類的成員沒有嚴格的訪問控制限制,這與其他面相對對象語言有區別。關於私有屬性和私有方法,有如下要點: 1、通常我們約定,兩個下劃線開頭的屬性是私有的(private)。其他為公共的(public); 2、類內部可以訪問私有屬性(方法); 3、類外 ...
  • C++ 訪問說明符 訪問說明符是 C++ 中控制類成員(屬性和方法)可訪問性的關鍵字。它們用於封裝類數據並保護其免受意外修改或濫用。 三種訪問說明符: public:允許從類外部的任何地方訪問成員。 private:僅允許在類內部訪問成員。 protected:允許在類內部及其派生類中訪問成員。 示 ...
  • 寫這個隨筆說一下C++的static_cast和dynamic_cast用在子類與父類的指針轉換時的一些事宜。首先,【static_cast,dynamic_cast】【父類指針,子類指針】,兩兩一組,共有4種組合:用 static_cast 父類轉子類、用 static_cast 子類轉父類、使用 ...
  • /******************************************************************************************************** * * * 設計雙向鏈表的介面 * * * * Copyright (c) 2023-2 ...
  • 相信接觸過spring做開發的小伙伴們一定使用過@ComponentScan註解 @ComponentScan("com.wangm.lifecycle") public class AppConfig { } @ComponentScan指定basePackage,將包下的類按照一定規則註冊成Be ...
  • 操作系統 :CentOS 7.6_x64 opensips版本: 2.4.9 python版本:2.7.5 python作為腳本語言,使用起來很方便,查了下opensips的文檔,支持使用python腳本寫邏輯代碼。今天整理下CentOS7環境下opensips2.4.9的python模塊筆記及使用 ...