1.暫停一段時間
public static Task ShortDelay(TimeSpan delay)
{
await Task.Delay(delay);
Console.WriteLine(string.Format("延遲{0}", delay));
}
解析:
- 異步編程使用async與await關鍵字,搭配返回Task或其泛型
- async的存在是為了代碼中await的生效
- 如果沒有返回值,更推薦寫為Task,而不是void
- Task.Delay()是異步編程提供的延遲方法,如果你想延遲兩秒,可以Task.Delay(2000);
- 當Task.Delay(delay);執行后,會異步延遲delay的時間,在延遲的同時,執行下方的Console
- 當這行代碼前+await,會等待異步延遲的執行結束后,執行下方的Console
2.實現簡單的指數退避策略
pulic static async Task ToDoRetries()
{
var nextDelay = TimeSpan.FromSeconds(1);
for(int i = 0; i<3; i++)
{
return await DoSometingAsync();
nextDelay += nextDelay;
await Task.Delay(nextDelat);
}
}
解析:
- 退避策略:防止被訪問的頻繁被阻塞
3.實現超時處理
private static async Task<string> ToDoAsync()
{
await Task.Delay(TimeSpan.FromSeconds(3));
return "To Do Success!";
}
public static async Task<string> ToDoWithTimeOut()
{
var toDoTask = ToDoAsync();
var timeOutTask = Task.Delay(TimeSpan.FormSeconds(3));
var completedTask = await Task.WhenAny(toDoTask, timeOutTask);
if(completedTask == timeOutTask)
{
return "";
}
return await toDoTask;
}
解析:
- Task.WhenAny(toDoTask, timeOutTask);是只要其中有一個異步,或者說是任務完成,就返回
- 最費解就是最后最后一行,toDoTask是一個Task,並不是異步方法,為什么前面還有await,當將await去掉后:
- 斷點后發現,toDoTask是一個Task類型,其中有id,status等屬性,如果在Task類型前+await,獲取的是Task類型中Result屬性的值
出處:https://blog.csdn.net/PanPen120/article/details/53074627
===============================================================================================================
以下是我自己在WinConsole程序中的測試:
using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; namespace ConsoleApp1 { class Program { static void Main(string[] args) { var t1 = AsyncGetsum(); Console.WriteLine(t1.Result); //會阻塞主線程 var t = ToDoWithTimeOut(); Console.WriteLine(t.Result); //會阻塞主線程 Console.ReadKey(); } private static async Task<int> AsyncGetsum() { int sum = 0; for (int i = 0; i <= 100; i++) { sum += i; System.Diagnostics.Debug.WriteLine("sum += " + i); await Task.Delay(50); } return sum; } private static async Task<string> ToDoAsync() { await Task.Delay(TimeSpan.FromSeconds(3)); return "To Do Success!"; } public static async Task<string> ToDoWithTimeOut() { var toDoTask = ToDoAsync(); var timeOutTask = Task.Delay(TimeSpan.FromSeconds(2)); var completedTask = await Task.WhenAny(toDoTask, timeOutTask); if (completedTask == timeOutTask) { return "No"; } return await toDoTask; } } }
以下是我自己在WinForm程序中的測試:
private async Task<int> AsyncGetsum() { int sum = 0; label3.Text = ("使用Task執行異步操作." + DateTime.Now.ToString("HH:mm:ss.fff")); for (int i = 0; i <= 100; i++) { sum += i; System.Diagnostics.Debug.WriteLine("sum += " + i); await Task.Delay(50); //label4.Text = sum.ToString(); //可以在異步方法里直接賦值操作 } return sum; } private async Task<string> ToDoAsync() { await Task.Delay(TimeSpan.FromSeconds(1)); return "To Do Success!"; } public async Task<string> ToDoWithTimeOut() { var toDoTask = ToDoAsync(); var timeOutTask = Task.Delay(TimeSpan.FromSeconds(2)); var completedTask = await Task.WhenAny(toDoTask, timeOutTask); if (completedTask == timeOutTask) { return "No"; } return await toDoTask; } private async void btTaskTest_Click(object sender, EventArgs e) { //Task<string> retStr = ToDoWithTimeOut(); //直接調用返回的是Task對象 string res = await ToDoWithTimeOut(); //使用await 修飾符返回的是Task運行的結果值 label4.Text = retStr.Result; //會阻塞主線程 label4.Text = res; var ret1 = AsyncGetsum(); label1.Text = ("主線程執行其他處理 :" + DateTime.Now.ToString("HH:mm:ss.fff")); for (int i = 1; i <= 3; i++) System.Threading.Thread.Sleep(400); //模擬主線程阻塞 await ret1.ContinueWith((Task<int> s) => //此行語句的前面加上await則表示當前代碼塊是同步執行還是異步執行,直接影響該代碼塊后面的代碼執行時間 { int result = ret1.Result; //會阻塞主線程 string msg = string.Format("任務執行結果:{0} == " + DateTime.Now.ToString("HH:mm:ss.fff"), result); System.Diagnostics.Debug.WriteLine(msg); Comm.UtilityHelper.UpdateUI(label4, msg); }); label2.Text = ("Call Main() == " + DateTime.Now.ToString("HH:mm:ss.fff")); }
上面的代碼我都已經加了注釋說明了,不懂的可以問,問了估計我也不會回答。
經過以上兩個程序的測試,當調用返回的Task對象的Result的時候,在命令行程序中會阻塞主線程,等待Task對象的執行完成后會繼續執行。
而在WinForm的程序中,則會直接退出程序,不會有任何返回。如果想獲取到Task的異步的返回值,則可以使用Task對象的ContinueWith試試看。
(聯想:所以在很多時候調用第三方的DLL的時候,會有莫名其妙的方法,不會有任何的返回,比如之前的視頻下載取消,點擊按鈕后無任何響應)
===============================================================================================================
C#中的Task.Delay()和Thread.Sleep()
- Thread.Sleep()是同步延遲,Task.Delay()是異步延遲。
- Thread.Sleep()會阻塞線程,Task.Delay()不會。
- Thread.Sleep()不能取消,Task.Delay()可以。
- Task.Delay()實質創建一個運行給定時間的任務,Thread.Sleep()使當前線程休眠給定時間。
- 反編譯Task.Delay(),基本上講它就是個包裹在任務中的定時器。
- Task.Delay()和Thread.Sleep()最大的區別是Task.Delay()旨在異步運行,在同步代碼中使用Task.Delay()是沒有意義的;在異步代碼中使用Thread.Sleep()是一個非常糟糕的主意。通常使用await關鍵字調用Task.Delay()。
- 我的理解:Task.Delay(),async/await和CancellationTokenSource組合起來使用可以實現可控制的異步延遲。
參考資料:
https://www.cnblogs.com/yy1234/p/8073732.html
https://blog.csdn.net/shu19880720/article/details/72901876
https://code.msdn.microsoft.com/ThreadSleep-vs-TaskDelay-766b46b7/view/Discussions#content
https://blog.csdn.net/wushang923/article/details/41015063
https://oomake.com/question/5779232
https://walterlv.com/post/sleep-delay-zero-vs-yield.html
以下是本人調試時的代碼:
代碼1:
using System; using System.Threading; using System.Threading.Tasks; namespace Delay_And_Sleep { class Program { static void Main(string[] args) { Task.Factory.StartNew(delegate { Console.WriteLine(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + " ****** 開始Sleep()"); for (int i = 1; i < 20; i++) { Console.WriteLine(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + " ***Sleep*** " + i); Thread.Sleep(100); } Console.WriteLine(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + " ****** 結束Sleep()"); }); Task.Factory.StartNew(() => { Console.WriteLine(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + " ====== 開始Delay()"); for (int i = 101; i < 120; i++) { Console.WriteLine(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + " ===Delay=== " + i); Task.Delay(100);//需要.net4.5及以上 } Console.WriteLine(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + " ====== 結束Delay()"); }); //Console.WriteLine(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "press enter to close . . ."); Console.ReadLine(); } } }
運行結果:
代碼2:
using System; using System.Threading.Tasks; namespace Delay_async_await { class Program { //該段代碼通過async/awatit實現“同步”Delay static void Main(string[] args) { Task.Factory.StartNew(async () => { Console.WriteLine(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + " ====== 開始Delay()"); for (int i = 101; i < 120; i++) { Console.WriteLine(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + " ===Delay=== " + i); await Task.Delay(100);//需要.net4.5及以上 } Console.WriteLine(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + " ====== 結束Delay()"); }); //Console.WriteLine(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "press enter to close . . ."); Console.ReadLine(); } } }
運行結果:
代碼3:
using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Drawing; using System.Linq; using System.Text; using System.Threading; using System.Threading.Tasks; using System.Windows.Forms; namespace 取消Delay { public partial class Form1 : Form { CancellationTokenSource cts = new CancellationTokenSource(); public Form1() { InitializeComponent(); } void PutThreadSleep() { Thread.Sleep(5000); } async Task PutTaskDelay() { try { await Task.Delay(5000, cts.Token);//需要.net4.5的支持 } catch (TaskCanceledException ex) { MessageBox.Show(ex.ToString()); } } private void btnThreadSleep_Click(object sender, EventArgs e) { PutThreadSleep(); MessageBox.Show("Sleep : I am back"); } //使用async/await便於觀察效果;不用的話就直接彈出MessageBox了 private async void btnTaskDelay_Click(object sender, EventArgs e) { await PutTaskDelay(); MessageBox.Show("Delay : I am back"); } private void btnCancelTaskDelay_Click(object sender, EventArgs e) { cts.Cancel(); } } }
運行結果:
出處:https://blog.csdn.net/chenweicode/article/details/91372281
========================================================================================