C#線程學習筆記十:async & await入門三

来源:https://www.cnblogs.com/atomy/archive/2019/12/18/12052082.html
-Advertisement-
Play Games

一、Task.Yield Task.Yield簡單來說就是創建時就已經完成的Task,或者說執行時間為0的Task,或者說是空任務,也就是在創建時就將Task的IsCompeted值設置為0。 我們知道await的Task完成時會釋放線程,然後從線程池中申請新的線程繼續執行await之後的代碼,那產 ...


    一、Task.Yield

    Task.Yield簡單來說就是創建時就已經完成的Task,或者說執行時間為0的Task,或者說是空任務,也就是在創建時就將Task的IsCompeted值設置為0。

    我們知道await的Task完成時會釋放線程,然後從線程池中申請新的線程繼續執行await之後的代碼,那產生的空任務又意義何在呢?

    事實上,Task.Yield產生的空任務僅僅是借await做嫁衣來達到線程切換的目的,即讓await之後的操作重新去線程池排隊申請新線程來繼續執行。

    這樣一來,假如有一個優先順序低但執行時間長的任務,可以將它拆分成多個小任務,每個小任務執行完成後就重新去線程池中排隊申請新線程來執行

下一個小任務,這樣任務就不會一直霸占著某個線程了(出讓執行權),讓別的優先急高或執行時間短的任務可以去執行,而不是乾瞪眼著急。

    class Program
    {
        static void Main(string[] args)
        {
            #region async & await入門三之Task.Yield 
            const int num = 10000;
            var task = YieldPerTimes(num);

            for (int i = 0; i < 10; i++)
            {
                Task.Factory.StartNew(n => Loop((int)n), num / 10);
            }

            Console.WriteLine($"Sum: {task.Result}");
            Console.Read();
            #endregion
        }

        /// <summary>
        /// 迴圈
        /// </summary>
        /// <param name="num"></param>
        private static void Loop(int num)
        {
            for (var i = 0; i < num; i++) ;
            Console.WriteLine($"Loop->Current thread id is:{Thread.CurrentThread.ManagedThreadId}");
            Thread.Sleep(10);
        }

        /// <summary>
        /// 分批出讓執行權
        /// </summary>
        /// <param name="times"></param>
        /// <returns></returns>
        private static async Task<int> YieldPerTimes(int num)
        {
            var sum = 0;
            for (int i = 1; i <= num; i++)
            {
                sum += i;
                if (i % 1000 == 0)
                {
                    Console.WriteLine($"Yield->Current thread id is:{Thread.CurrentThread.ManagedThreadId}");
                    Thread.Sleep(10);
                    await Task.Yield();
                }
            }
            return sum;
        }
    }
View Code

    運行結果如下:

    二、在WinForm中使用非同步Lambda表達式

        public Main()
        {
            InitializeComponent();

            //非同步表達式:async (sender, e)
            btnDoIt.Click += async (sender, e) =>
            {
                DoIt(false, "開始搬磚啦...");
                await Task.Delay(3000);
                DoIt(true, "終於搬完了。");
            };
        }

        private void DoIt(bool isEnable, string text)
        {
            btnDoIt.Enabled = isEnable;
            lblText.Text = text;
        }
View Code

    運行結果如下:

    三、滾動條應用

        private CancellationTokenSource source;
        private CancellationToken token;

        public ProcessBar()
        {
            InitializeComponent();
        }

        /// <summary>
        /// 初始化
        /// </summary>
        private void InitTool()
        {
            progressBar1.Value = 0;
            btnDoIt.Enabled = true;
            btnCancel.Enabled = true;
        }

        /// <summary>
        /// 開始任務
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private async void btnDoIt_Click(object sender, EventArgs e)
        {
            btnDoIt.Enabled = false;

            source = new CancellationTokenSource();
            token = source.Token;

            var completedPercent = 0;               //完成百分比
            const int loopTimes = 10;               //迴圈次數
            const int increment = 100 / loopTimes;  //進度條每次增加的進度值

            for (var i = 1; i <= loopTimes; i++)
            {
                if (token.IsCancellationRequested)
                {
                    break;
                }

                try
                {
                    await Task.Delay(200, token);
                    completedPercent = i * increment;
                }
                catch (Exception)
                {
                    completedPercent = i * increment;
                }
                finally
                {
                    progressBar1.Value = completedPercent;
                }
            }

            var msg = token.IsCancellationRequested ? $"任務被取消,已執行進度為:{completedPercent}%。" : $"任務執行完成。";
            MessageBox.Show(msg, "提示", MessageBoxButtons.OK, MessageBoxIcon.Information);

            progressBar1.Value = 0;
            InitTool();
        }

        /// <summary>
        /// 取消任務
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void btnCancel_Click(object sender, EventArgs e)
        {
            if (btnDoIt.Enabled) return;

            btnCancel.Enabled = false;
            source.Cancel();
        }
    }
View Code

    運行結果如下:

    四、BackgroundWorker

    與async & await不同的是,有時候可能需要一個額外的線程,它在後臺持續完成某個任務並不時與主線程通信,這時就需要用到BackgroundWorker類。

(主要用於GUI程式)

        private readonly BackgroundWorker bgWorker = new 
        BackgroundWorker();

        public ProcessBar()
        {
            InitializeComponent();

            //設置BackgroundWorker屬性
            bgWorker.WorkerReportsProgress = true;      //能否報告進度更新
            bgWorker.WorkerSupportsCancellation = true; //是否支持非同步取消

            //連接BackgroundWorker對象的處理程式
            bgWorker.DoWork += bgWorker_DoWork;
            bgWorker.ProgressChanged += bgWorker_ProgressChanged;
            bgWorker.RunWorkerCompleted += bgWorker_RunWorkerCompleted;
        }

        /// <summary>
        /// 開始執行後臺操作觸發,即調用BackgroundWorker.RunWorkerAsync時發生。
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private static void bgWorker_DoWork(object sender, DoWorkEventArgs e)
        {
            if (!(sender is BackgroundWorker worker))
            {
                return;
            }

            for (var i = 1; i <= 10; i++)
            {
                //判斷程式是否已請求取消後臺操作
                if (worker.CancellationPending)
                {
                    e.Cancel = true;
                    break;
                }

                worker.ReportProgress(i * 10);  //觸發BackgroundWorker.ProgressChanged事件
                Thread.Sleep(200);              //線程掛起200毫秒
            }
        }

        /// <summary>
        /// 調用BackgroundWorker.ReportProgress(System.Int32)時發生
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void bgWorker_ProgressChanged(object sender, ProgressChangedEventArgs e)
        {
            progressBar1.Value = e.ProgressPercentage;  //非同步任務的進度百分比
        }

        /// <summary>
        /// 當後臺操作已完成或被取消或引發異常時發生
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void bgWorker_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e)
        {
            MessageBox.Show(e.Cancelled ? $@"任務已被取消,已執行進度為:{progressBar1.Value}%" : $@"任務執行完成,已執行進度為:{progressBar1.Value}%");
            progressBar1.Value = 0;
        }

        /// <summary>
        /// 開始任務
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void btnDoIt_Click(object sender, EventArgs e)
        {
            //判斷BackgroundWorker是否正在執行非同步操作
            if (!bgWorker.IsBusy)
            {
                bgWorker.RunWorkerAsync();  //開始執行後臺操作
            }
        }

        /// <summary>
        /// 取消任務
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void btnCancel_Click(object sender, EventArgs e)
        {
            bgWorker.CancelAsync(); //請求取消掛起的後臺操作
        }
View Code

    運行結果如下:

    參考自:

    https://www.cnblogs.com/dudu/archive/2018/10/24/task-yield.html

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

    後記:

    關於更詳細的BackgroundWorker知識,可查看此篇博客:

    https://www.cnblogs.com/sparkdev/p/5906272.html


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

-Advertisement-
Play Games
更多相關文章
  • 項目需要引用NPOI的Nuget包:DotNetCore.NPOI-v1.2.2 本篇文章是對WebAPI項目使用NPOI操作Excel時的幫助類:ExcelHelper的改進優化做下記錄: 備註:下麵的幫助類代碼使用的文件格式為:xlsx文件,xlsx相對xls的優缺點代碼里有註釋,推薦使用xls ...
  • 時間如流水,只能流去不流回! 點贊再看,養成習慣,這是您給我創作的動力! 本文 Dotnet9 https://dotnet9.com 已收錄,站長樂於分享dotnet相關技術,比如Winform、WPF、ASP.NET Core等,亦有C++桌面相關的Qt Quick和Qt Widgets等,只分 ...
  • [toc] 概述 在前幾篇的博文中,我們已經學習到瞭如何運用實體和值對象。隨著我們所在領域的不斷深入,領域模型變得逐漸清晰,我們已經建立了足夠豐富的實體和值對象。但隨著實體和值對象的數量逐漸增多,它們之間的關係也顯得越來越複雜:實體A與實體B存在一對一的關係,實體B又與實體C存在一對多的關係。就這樣 ...
  • 在我們做項目的時候經常遇到需要動態配置系統的情況,比如說10臺電腦裝了同一個軟體,需要識別唯一碼,這時候我們會用到配置方法。 具體方法如下: 1) Config文件 裡面增加你需要的變數,具體用法如下: 怎麼取到對應的值呢? 2)XML文件 首先添加文件 然後寫內容 添加讀取類 怎麼取值呢? 3)註 ...
  • using System; using System.Collections.Generic; using System.Text; namespace 繼承 { class Program { static void Main(string[] args) { Mammal mammal = ne ...
  • 場景 現在有一個文件路徑 E:\\BTSData\\2019-11\\admin_20180918_1_1_2 需要獲取最後的文件名admin_20180918_1_1_2 需要獲取文件的上層目錄2019-11 需要獲取最後文件名中的最後的1和2 註: 博客主頁: https://blog.csdn ...
  • 場景 Winform中設置ZedGraph滑鼠懸浮顯示距離最近曲線上的點的坐標值和X軸與Y軸的標題: https://blog.csdn.net/BADAO_LIUMANG_QIZHI/article/details/103140781 上面博客能實現滑鼠懸浮顯示最近的曲線上點的坐標值與X軸和Y軸的 ...
  • Supervisor 是用 Python 開發的 Linux/Unix 系統下的一個進程管理工具。它可以使進程脫離終端,變為後臺守護進程(daemon)。實時監控進程狀態,異常退出時能自動重啟。 Supervisor 不支持任何版本的 Window 系統;僅支持在 Python2.4 或更高版本,但 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...