目錄
- 異步編程
- async/await特性異步編程
- BackgroundWorker類異步編程模式
- 任務并行庫異步編程模式
- BeginInvoke與EndEInvoke異步編程模式
異步編程
async/await特性異步編程
- 使用模型:
private await Task<int> YibuAsync(int a)//定義一個異步方法 YibuAsync await關鍵字指示編譯器方法內部可能會存在await運算式
{
//do something
int b = await AnotherAsync(a);//如果只是標記了async關鍵字,但方法內沒有await運算式,方法仍將同步執行
return b;//b實際回傳到了Task.Result中
}
Task<int> t = YibuAsync(10);//呼叫異步方法
//doing something
異步方法:async和await關鍵字同時存在,
- 控制流程:
- 呼叫異步方法,呼叫后立即回傳一個Task
型別的物件, - 呼叫異步方法后執行到await運算式后回傳
- 繼續執行呼叫者后續代碼,
- 當需要使用異步方法執行結果時,若異步方法任未回傳,將生成一個continue委托,當操作完成的時候呼叫continue委托,這個continue委托將控制權重新回傳到”async”方法對應的await喚醒點處,
- 異步方法回傳型別
void呼叫并回傳,呼叫異步方法后不再做任何處理TaskTask<T>ValueTask<T>
- await運算式
await運算式由await關鍵字和一個空閑物件組成(任務),這個任務可以是Task型別的物件,也可以不是,默認情況下,這個任務在當前執行緒上異步執行,空閑物件指awaitable型別的實體,awaitable型別指包含GetAwaiter方法的型別,該方法沒有引數,回傳一個awaiter型別的物件,awaier型別包含以下成員:
bool IsCompleted{get;}
void OnCompleted(Action);
以及一下成員之一:
void GetResult();
T GetResult(); - Task.Run()方法
- Task.Run的方法簽名及回傳型別
Run(Action action) 回傳型別 Task
Run(Action action,CancellationToken token) 回傳型別 Task
Run(Func<TResult> function) 回傳型別 Task<TResult>
Run(Func<TResult> functiom,CancellationToken token) 回傳型別 Task<TResult>
Run(Func<Task> function) 回傳型別 Task
Run(Func<Task> function,CancellationToken token) 回傳型別 Task
Run(Func<Task<TResult>> function) 回傳型別 Task<TResult>
Run(Func<Task<TResult>> function,CancellationToken token) 回傳型別 Task<TResult>
注:Action委托:無參無回傳值;Func委托:無參有回傳值,
BackgroundWorker類異步編程模式
使用BackgroundWorker類創建一個后臺執行緒,并和主執行緒通信,該類主要成員如下:
屬性:WorkerReportsProgress //設定后臺執行緒是否把它的進度匯報給主執行緒,
WorkerSupportsCancellation //設定后臺執行緒是否支持從主執行緒取消,
IsBusy //檢查后臺執行緒是否正在運行,
CancellationPending //檢查后臺執行緒是否需要被取消,
方法:RunWorkerAsync() //獲取后臺執行緒,并執行DoWork事件處理程式
CancelAsync() //把CancellationPending屬性設定為True,DoWork事件處理程式需要檢查這個屬性來決定是否應該停止該處理,
RePortProgress()
事件:DoWork
ProgressChanged
RunWorkerCompleted
控制流程:實體化BackgroundWorker類,創建后臺執行緒,設定后臺執行緒是否向主執行緒匯報進度屬性(WorkerReportsProgress)、后臺執行緒是否支持從主執行緒取消屬性(WorkerSupportsProgress),在主執行緒呼叫RunWorkerAsync()方法,獲取后臺執行緒,并觸發DOWork事件,執行Dowork事件處理程式,若要向主執行緒匯報進度,則DoWork事件處理程式呼叫ReportProgress()方法,觸發ProgressChanged事件,主執行緒可以用附加到ProgressChanged事件上的處理程式,若要取消后臺執行緒的執行,則在主執行緒中呼叫CancelSAsync()方法,該方法不會立即取消后臺執行緒的執行,而是將CancellationPending的屬性設定為True,后臺執行緒的DoWork事件處理程式需要定期檢查CancellationPending的屬性,來判斷是否需要退出,
任務并行庫異步編程模式
Parallel.For回圈與Parallel.Foreach回圈:許多時候,在使用這兩個結構時,每一次迭代都依賴于前一次迭代的計算或行為,但有時候不是,如果迭代之間彼此獨立,并且程式運行在多處理機上,那么若能將不同的的迭代放在不同的處理器上進行的話,將受益匪淺,Parallel.For與Parallel.Foreach結構就是這樣做的,
這兩個結構的形式是包含輸入引數的方法,Parallel.For方法有12個多載,其中最簡單的簽名如下:
public static ParallelLoopResult.For(int fromInclusive,int toExclusive,Action body);
- fromInclusive引數是迭代系列的第一個引數,
- ToExclusive引數是比迭代系列最后一個索引號大1的整數,即index<ToExclusive計算的一樣,
- 實體代碼
using System.Threading.Tasks;
Parallel.For(0,15,i=>Console.WriteLine($"The square of {i} is {i*i}"));
輸出結果為無序的0到15的平方,
另一個并行回圈結構是Parallel.Foreach(),該方法有多個多載,其中最簡單的如下:
static ParallelLoopResult ForEach<TSource>(IEnumerable<TSource> source,Action<TSource> body)
- TSource 是集合中物件的型別,
- source 是Tsource物件的集合,
- body是要應用到集合中每一個元素上的Lambda運算式,
BeginInvoke與EndEInvoke異步編程模式
委托有兩個方法:BeginInvoke與EndInvoke,當委托物件的方法串列中只有一個方法時,可使用這里兩個方法使其在一個獨立的執行緒中異步執行,分為三種模式,分別是等待直到完成模式、輪詢模式和回掉模式,
先來介紹委托型別中的BeginInvoke與EndInvoke方法
- BeginInvoke方法
- BeiginInvoke方法的引陣列成:參考方法需要的引數、callback、state,
- BeginInvoke從執行緒池中獲取一個執行緒,并讓參考方法在新執行緒中開始運行,
- BeginInvoke方法回傳給呼叫執行緒一個實作IAsyncResult介面的物件的參考,這個介面參考包含了在執行緒池中運行的異步方法的當前狀態,
- 代碼示例:
IAsyncResult iar = del.BeginInvoke(a,b,null,null);
a,b是委托方法的引數,del是對應的委托實體,
- EndInvoke方法
該方法獲取由異步方法呼叫回傳的值,并且釋放執行緒使用的資源:
- 它接受一個由BeginInvoke方法回傳的IAsyncResult物件的參考作為引數,并找到它關聯的執行緒,
- 如果執行緒池中的執行緒已經退出,則其清理退出執行緒的狀態并釋放其資源,找到參考方法的回傳值,并將它作為回傳值回傳,
- 如果當EndInvoke被呼叫時,執行緒池中的執行緒仍在運行,呼叫執行緒就會停止并等待其完成,
- 代碼示例:
int result = EndInvoke(iar);
result是異步方法的回傳值,
- 等待直到完成模式
在發起異步方法并做了一些其他處理后,就中斷等待異步方法完成后再繼續, - 輪詢模式
原始執行緒發起異步方法的呼叫,做一些其他的處理,并通過定期檢查IAsyncResult的IsCompleted屬性判斷執行緒是否完成,如果完成,則呼叫EndInvoke方法,否則,做一些其他處理,間隔一段時間再檢查, - 回呼模式
原始執行緒呼叫異步執行緒后不在管了,當異步方法呼叫結束后,系統在新執行緒中呼叫用戶自定義的方法來處理結果,并且呼叫委托的EndInvoke方法,這個用戶自定義的方法叫回掉方法,
轉載請註明出處,本文鏈接:https://www.uj5u.com/net/373637.html
標籤:C#
上一篇:vs2019 除錯服務器代碼
