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
  • 用例演示 - 創建實體 本節將演示一些示例用例並討論可選場景。 創建實體 從實體/聚合根類創建對象是實體生命周期的第一步。聚合/聚合根規則和最佳實踐部分 建議為Entity類創建一個主構造函數,以保證創建一個有效的實體。因此,無論何時我們需要創建實體的實例,我們都應該使用那個構造函數 參見下麵的問題 ...
  • 領域邏輯 & 應用邏輯 如前所述,領域驅動設計中的業務邏輯分為兩部分(層):領域邏輯和應用邏輯: 領域邏輯由系統的核心領域規則組成,應用邏輯實現應用特定的用例 雖然定義很明確,但實現起來可能並不容易。您可能無法決定哪些代碼應該位於應用程式層,哪些代碼應該位於領域層。本節試圖解釋其中的差異 多個應用程 ...
  • 表弟大學快畢業了,學了一個學期Python居然還不會寫學生管理系統,真的給我丟臉啊,教他又不肯學,還讓我直接給他寫,我真想兩巴掌上去,最終還是寫了給他,誰讓他是我表弟呢,關鍵時候還是得幫他一把! 寫完了放在那也是放著,所以今天分享給大家吧! 話不多說,咱們直接開始吧! 代碼解析 一、登錄頁面 1、定 ...
  • Zookeeper3.7源碼剖析 能力目標 掌握Zookeeper中Session的管理機制 能基於Client進行Debug測試Session創建/刷新操作 能搭建Zookeeper集群源碼配置 掌握集群環境下Leader選舉啟動過程 能說出Zookeeper選舉過程中的概念 能說出Zookeep ...
  • 前言 今天給大家分享一下我自己寫的筆記,純純的都是乾貨,關於字好像也能看。這是我學python整理出來的一些資料,希望對大家 有用。想要更多的資料那就的給一個關註了… python學習交流Q群:903971231### #導入Counter from collections import Count ...
  • Hi,大家好,我是Mic 一個工作5年的粉絲找到我。 他說: “Mic老師,你要是能回答出這個問題,我就佩服你” 我當場就懵了,現在打賭都這麼隨意了嗎? 我問他問題是什麼,他說“Kafka如何避免重覆消費的問題!” 下麵看看普通人和高手的回答! 普通人: Kafka怎麼避免重覆消費就是我們可以通過 ...
  • 前言 Steam是由美國電子游戲商Valve於2003年9月12日推出的數字發行平臺,被認為是電腦游戲界最大的數位發行平臺之一,Steam平臺是全球最大的綜合性數字發行平臺之一。玩家可以在該平臺購買、下載、討論、上傳和分享游戲和軟體。 而每周的steam會開啟了一輪特惠,可以讓游戲打折,而玩家就會 ...
  • 本篇內容將在上一篇已有的內容基礎上,進一步的聊一下項目中使用JPA的一些高階複雜場景的實踐指導,覆蓋了主要核心的JPA使用場景,可以讓你在需求開發的時候對JPA的使用更加的游刃有餘。 ...
  • 1.路徑處理 1.找模塊:sys.path import sys print(sys.path) - 1.理解 - 1.是python去查找包或模塊 - 2.項目開始根目錄,python內置的目錄 - 3.雖然說python的安裝目錄下也可以存放我們寫的模塊,但是不建議(太多了,不大好找) - 4. ...
  • Go 語言入門練手項目系列 01 基於命令行的圖書的增刪查改 02 文件管理 持續更新中... > 本文來自博客園,作者:Arway,轉載請註明原文鏈接:https://www.cnblogs.com/cenjw/p/gobeginner-proj-bookstore-cli.html 介紹 這是一 ...