async和await詳解

来源:https://www.cnblogs.com/dfcq/archive/2022/06/19/16388646.html
-Advertisement-
Play Games

async和await詳解 1.非UI線程中執行 Test()函數帶有async 和await ,返回值寫成Task。 1 using System; 2 using System.Threading; 3 using System.Threading.Tasks; 4 5 namespace _0 ...


 async和await詳解

 1.非UI線程中執行

Test()函數帶有async 和await ,返回值寫成Task。
 1 using System;
 2 using System.Threading;
 3 using System.Threading.Tasks;
 4 
 5 namespace _00_測試
 6 {
 7     class Program
 8     {
 9         static void Main(string[] args)
10         {
11             Console.WriteLine($"Main Start:{Thread.CurrentThread.ManagedThreadId}");
12             Task task = Test();
13             Console.WriteLine($"Main End:{Thread.CurrentThread.ManagedThreadId}");
14             Console.ReadKey();
15         }
16         private async static Task Test()
17         {
18             Console.WriteLine($"當前主線程ID::{Thread.CurrentThread.ManagedThreadId}");
19             Console.WriteLine($"是否是線程池線程:{Thread.CurrentThread.IsThreadPoolThread}");
20             Task task1 = Task.Factory.StartNew(() =>
21             {
22                 Thread.Sleep(100);
23                 Console.WriteLine($"task1:{Thread.CurrentThread.ManagedThreadId}");
24                 Console.WriteLine($"是否是線程池線程:{Thread.CurrentThread.IsThreadPoolThread}");
25             });
26             await task1;
27 
28             Console.WriteLine($"task1 結束後的線程ID:{Thread.CurrentThread.ManagedThreadId}");
29             Console.WriteLine($"是否是線程池線程:{Thread.CurrentThread.IsThreadPoolThread}");
30 
31             await Task.Run(() =>
32             {
33                 Thread.Sleep(100);
34                 Console.WriteLine($"task2:{Thread.CurrentThread.ManagedThreadId}");
35                 Console.WriteLine($"是否是線程池線程:{Thread.CurrentThread.IsThreadPoolThread}");
36             });
37             Console.WriteLine($"Test End:{Thread.CurrentThread.ManagedThreadId}");
38             Console.WriteLine($"是否是線程池線程:{Thread.CurrentThread.IsThreadPoolThread}");
39         }
40     }
41 }

 

 

 

 

 

 

 上面是控制台應用程式,主線程的ID為1,第一個await和後面的代碼都是子線程完成的。第二個await和後面的代碼,也是子線程完成的。在非UI線程中執行的async非同步方法,await等待的非同步操作和後面要執行的代碼,都是從線程池獲取一個線程來執行的。

 

2.UI線程中執行

 1 using System;
 2 using System.Collections.Generic;
 3 using System.ComponentModel;
 4 using System.Data;
 5 using System.Drawing;
 6 using System.Linq;
 7 using System.Text;
 8 using System.Threading;
 9 using System.Threading.Tasks;
10 using System.Windows.Forms;
11 
12 namespace _009__資料庫
13 {
14     public partial class Form1 : Form
15     {
16         public Form1()
17         {
18             InitializeComponent();
19         }
20 
21         private async void button1_Click(object sender, EventArgs e)
22         {
23             Console.WriteLine($"Main Start:{Thread.CurrentThread.ManagedThreadId}");
24             Task task = Test();
25             await task;
26             Console.WriteLine($"Main End:{Thread.CurrentThread.ManagedThreadId}");
27             Console.ReadKey();
28         }
29         private async static Task Test()
30         {
31             Console.WriteLine($"當前主線程ID::{Thread.CurrentThread.ManagedThreadId}");
32             Console.WriteLine($"是否是線程池線程:{Thread.CurrentThread.IsThreadPoolThread}");
33             Task task1 = Task.Factory.StartNew(() =>
34             {
35                 Thread.Sleep(100);
36                 Console.WriteLine($"task1:{Thread.CurrentThread.ManagedThreadId}");
37                 Console.WriteLine($"是否是線程池線程:{Thread.CurrentThread.IsThreadPoolThread}");
38             });
39             await task1;
40 
41             Console.WriteLine($"task1 結束後的線程ID:{Thread.CurrentThread.ManagedThreadId}");
42             Console.WriteLine($"是否是線程池線程:{Thread.CurrentThread.IsThreadPoolThread}");
43 
44             await Task.Run(() =>
45             {
46                 Thread.Sleep(100);
47                 Console.WriteLine($"task2:{Thread.CurrentThread.ManagedThreadId}");
48                 Console.WriteLine($"是否是線程池線程:{Thread.CurrentThread.IsThreadPoolThread}");
49             });
50             Console.WriteLine($"Test End:{Thread.CurrentThread.ManagedThreadId}");
51             Console.WriteLine($"是否是線程池線程:{Thread.CurrentThread.IsThreadPoolThread}");
52         }
53     }
54 }

 

 

 在UI線程中,async切換線程的規律和非UI線程不一樣了。在UI線程中,await後面緊跟的代碼,一直都是在UI線程中執行的。

註意:非UI線程中,await後面的動作都是子線程完成的;UI線程中,await後面的動作都是主線程完成的。

3.帶返回值的非同步方法

非UI線程

 1 using System;
 2 using System.Threading;
 3 using System.Threading.Tasks;
 4 
 5 namespace _00_測試
 6 {
 7     class Program
 8     {
 9         static void Main(string[] args)
10         {
11             Console.WriteLine($"Main Start:{Thread.CurrentThread.ManagedThreadId}");
12             Task<int> task = Test();
13             Console.WriteLine($"結果為:{task.Result}");
14             Console.WriteLine($"Main End:{Thread.CurrentThread.ManagedThreadId}");
15             Console.ReadKey();
16         }
17         private async static Task<int> Test()
18         {
19             int Value = 0;
20             Task task1 = Task.Factory.StartNew(() =>
21             {
22                 Value++;
23                 Thread.Sleep(100);
24             });
25             await task1;
26             return Value;
27         }
28     }
29 }

 

 

 執行Test()非同步方法,然後獲取非同步方法的返回值,執行非同步方法的線程會一直阻塞,直到等到要獲取的返回值。但是,在UI線程中,執行非同步方案的是主線程,直接就死鎖了。

UI線程

 1 using System;
 2 using System.Collections.Generic;
 3 using System.ComponentModel;
 4 using System.Data;
 5 using System.Drawing;
 6 using System.Linq;
 7 using System.Text;
 8 using System.Threading;
 9 using System.Threading.Tasks;
10 using System.Windows.Forms;
11 
12 namespace _009__資料庫
13 {
14     public partial class Form1 : Form
15     {
16         public Form1()
17         {
18             InitializeComponent();
19         }
20 
21         private  void button1_Click(object sender, EventArgs e)
22         {
23             Console.WriteLine($"Main Start:{Thread.CurrentThread.ManagedThreadId}");
24             Task<int> task = Test();
25             Console.WriteLine($"結果為:{task.Result}");
26             Console.WriteLine($"Main End:{Thread.CurrentThread.ManagedThreadId}");
27             Console.ReadKey();
28         }
29         private async static Task<int> Test()
30         {
31             int Value = 0;
32             Task task1 = Task.Factory.StartNew(() =>
33             {
34                 Value++;
35                 Thread.Sleep(100);
36             });
37             await task1;
38             return Value;
39         }
40     }
41 }

在winform中,點擊按鈕,界面直接卡死了!!!

分析, 執行Test()非同步方法,然後獲取非同步方法的返回值,但是在UI線程中,await後面的操作是UI線程執行的。那麼,首先非同步方法執行了await中的非同步任務,UI線程已經開始等這個執行結果了,UI線程阻塞等待中;而await後面的

return Value;這一行,需要UI線程執行啊,此時UI線程阻塞等結果呢無法執行其他操作,就這麼UI等返回值,子線程等UI線程等UI線程來執行  return Value;這行代碼。誰也不讓誰的等待下去,這就是死鎖了。

 


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

-Advertisement-
Play Games
更多相關文章
  • 大佬的理解->Java多線程(一)多線程基礎 大佬的理解->Java多線程(二)常用的實現多線程的兩種方式 1、繼承Thread類 ​ 繼承Thread必須重寫run方法,(具體業務執行方法,需要執行的業務方法,定義在此方法中),註意此方法是線程啟動後線程自動調用的; 案例 public class ...
  • 前言 還有多少人不會python的控制結構,在評論區告訴我,讓我一個個點名提問。今天,就教會你python的控制結構… 分行與縮進 分行 •一條語句占用一行 •過長的語句可以占用多行,使用\或()控制換行 •[]、{}、()可以直接跨越多行,在列表、字典、元組中需要換行的時候也可以不用添加續行符 a ...
  • 3 Skywalking源碼導入 接上文,已經學習了Skywalking的應用,接下來我們將剖析Skywalking源碼,深度學習Skywalking Agent。 3.1 源碼環境搭建 當前最新版本是8.3.0,我們首先找到8.3.0的版本,然後下載並導入到IDEA,下載地址 https://gi ...
  • 《乘風破浪的姐姐3》王心凌一騎絕塵,破收視率,多年後再次全網爆火,某音截止現在差不多3500W粉絲,五月份熱門女星排名,弔打其它所有人,不愧是我女神! 但是這個熱度,感覺她的歌曲和MV,已經離收費越來越近了,於是我連夜用Python把所有MV 和歌曲離線,今天先給大家分享MV的方法。 女神鎮樓! 話 ...
  • 序列號 序列號是序列化和反序列化的唯一標識,是一個長整型數值; 如果類中不自己定義序列號,系統會自動生成一個序列號; 當一方實體類發生改變,而調用方的序列號是不會跟著改變的,不知道對象已修改,會導致兩邊序列號不一致,反序列化失敗; 所以要求必須手動生成一個序列號; 手動生成序列號後,可以解決目標類發 ...
  • 在我國自動化控制領域應用較廣泛的工業自動化組態軟體有Wonderware公司InTouch、西門子公司Wincc、GE公司iFix。國內也有一些傳統組態軟體廠商,使用的功能和形式基本上十分類似,受當時開發環境和組態軟體框架的限制,也很難做較大的改變。 ...
  • 什麼是JORM框架? 全稱 :Json Object Relational Mapping ,它是通過JSON 對象 去實現資料庫的一個關係映射 ,我理想中完整的JORM包含功能有 ·1、表權授權 2、欄位級別授權 3、查詢返回備註 4、可以配置化 5、支持豐富的SQL語法 6、數據驗證 7、JSO ...
  • 一:背景 1. 一個很好奇的問題 我們在學習 C# 的過程中,總會聽到一個詞叫做 內核態 ,比如說用 C# 讀寫文件,會涉及到代碼從 用戶態 到 內核態 的切換,用 HttpClient 獲取遠端的數據,也會涉及到 用戶態 到 內核態 的切換,那到底這是個什麼樣的交互流程?畢竟我們的程式是無法操控 ...
一周排行
    -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模塊筆記及使用 ...