C#異步編程由淺入深(三)之詳解Awaiter

第C#異步編程由淺入深(三)之詳解Awaiter上一篇末尾提到了Awaiter這個類型，上一篇說了，能await的對象，必須包含GetAwaiter()方法，不清楚的朋友可以看上篇文章。那么，Awaiter到底有什么特別之處呢？

首先，從上篇文章我們知道，一個Awaiter必須實現(xiàn)INotifyCompletion接口，這個接口定義如下：

namespaceSystem.Runtime.CompilerServices

///summary

///Representsanoperationthatwillschedulecontinuationswhentheoperationcompletes.

////summary

publicinterfaceINotifyCompletion

///summarySchedulesthecontinuationactiontobeinvokedwhentheinstancecompletes./summary

///paramname="continuation"Theactiontoinvokewhentheoperationcompletes./param

///exceptioncref="System.ArgumentNullException"Theparamrefname="continuation"/argumentisnull(NothinginVisualBasic)./exception

voidOnCompleted(Actioncontinuation);

}

除此之外還必須包含IsCompleted屬性和包含GetResult()方法。

注意OnCompleted的參數(shù)是一個Action委托，并且不出意外的話，委托里面總會有一個地方調(diào)用一個MoveNext()方法，它推動狀態(tài)機到達下一個狀態(tài)，然后執(zhí)行下一個狀態(tài)需要執(zhí)行的代碼。

那么，知道這個有什么用呢？第一，它是你充分了解async/await這套機制的基礎(chǔ)，包括與之相關(guān)的同步上下文、執(zhí)行上下文、死鎖問題等，第二，它可以實現(xiàn)一些特殊的功能。

從上一篇我們知道，OnCompleted中的contination的主要目的是推動狀態(tài)機的執(zhí)行，也就是推動異步方法中await后面部分的代碼執(zhí)行。從這里看出，continuation的執(zhí)行是受我們控制的，因此我們可以直接執(zhí)行它，或是等待某個條件成熟然后執(zhí)行它，我們可以把它放到線程池執(zhí)行，也可以單獨起一個線程執(zhí)行。譬如，我們可以讓await后面部分的代碼直接在線程池上執(zhí)行。

publicstaticasyncTaskAwaiterTest()

Console.WriteLine($"是否是線程池線程？{Thread.CurrentThread.IsThreadPoolThread}");

awaitdefault(SkipToThreadPoolAwaiter);

Console.WriteLine($"是否是線程池線程？{Thread.CurrentThread.IsThreadPoolThread}");

staticvoidMain(string[]args)

_=AwaiterTest();

Console.ReadLine();

publicstructSkipToThreadPoolAwaiter:INotifyCompletion

publicboolIsCompleted=false;

publicvoidGetResult()

Console.WriteLine("調(diào)用GetResult以獲取結(jié)果");

publicvoidOnCompleted(Actioncontinuation)

Console.WriteLine("調(diào)用OnCompleted，把Await后面部分要執(zhí)行的代碼傳遞過來（傳遞MoveNext，以推動狀態(tài)機流轉(zhuǎn)）");

ThreadPool.QueueUserWorkItem(state=

Console.WriteLine("開始執(zhí)行Await后面部分的代碼");

continuation();

Console.WriteLine("后面部分的代碼執(zhí)行完畢");

Console.WriteLine("返回調(diào)用線程");

publicSkipToThreadPoolAwaiterGetAwaiter()

Console.WriteLine("獲得Awaiter");

returnthis;

}

這是一個控制臺程序，輸出結(jié)果如下。

是否是線程池線程？False

獲得Awaiter

調(diào)用OnCompleted，把Await后面部分要執(zhí)行的代碼傳遞過來（傳遞MoveNext，以推動狀態(tài)機流轉(zhuǎn)）

返回調(diào)用線程

開始執(zhí)行Await后面部分的代碼

調(diào)用GetResult以獲取結(jié)果

是否是線程池線程？True

后面部分的代碼執(zhí)行完畢

特別注意一下，第五步說明可能有點疑惑，怎么第六步不是打印是否是線程池線程？原因是部分awaiter是有返回值的，在執(zhí)行await后面部分的代碼時，會首先調(diào)用GetResult()以獲取結(jié)果。這對編譯器改造異步方法來說是一個固定的模式（上篇文章沒有體現(xiàn)這一步）。

把Awaiter改成有返回值嘗試。

publicstaticasyncTaskAwaiterTest()

Console.WriteLine($"是否是線程池線程？{Thread.CurrentThread.IsThreadPoolThread}");

varres=awaitdefault(SkipToThreadPoolAwaiter);

Console.WriteLine($"結(jié)果是{res}");

staticvoidMain(string[]args)

_=AwaiterTest();

Console.ReadLine();

publicstructSkipToThreadPoolAwaiter:INotifyCompletion

publicboolIsCompleted=false;

publicintGetResult()

Console.WriteLine("調(diào)用GetResult以獲取結(jié)果");

return1;

publicvoidOnCompleted(Actioncontinuation)

Console.WriteLine("調(diào)用OnCompleted，把Await后面部分要執(zhí)行的代碼傳遞過來（傳遞MoveNext，以推動狀態(tài)機流轉(zhuǎn)）");

ThreadPool.QueueUserWorkItem(state=

Console.WriteLine("開始執(zhí)行Await后面部分的代碼");

continuation();

Console.WriteLine("后面部分的代碼執(zhí)行完畢");

Console.WriteLine("返回調(diào)用線程");

publicSkipToThreadPoolAwaiterGetAwaiter()

Console.WriteLine("獲得Awaiter");

returnthis;

輸出如下

是否是線程池線程？False

獲得Awaiter

調(diào)用OnCompleted，把Await后面部分要執(zhí)行的代碼傳遞過來（傳遞MoveNext，以推動狀態(tài)機流轉(zhuǎn)）

返回調(diào)用線程

開始執(zhí)行Await后面部分的代碼

調(diào)用GetResult以獲取結(jié)果

結(jié)果是1

是否是線程池線程？True

后面部分的代碼執(zhí)行完畢

對照前面的文章來看，相信你應(yīng)該有所得，能解決你部分的疑惑。前面說到，我們可以控制continuation的執(zhí)行，那如果當前線程有同步上下文（SychronizationContext），我們是不是可以放到同步上下文中執(zhí)行？TaskAwaiter是會這么做的，如果你不想它使用同步上下文，你可以在Task實例上調(diào)用ConfigureAwait(false)，它表面后面部分的代碼將不會使用同步上下文執(zhí)行。

另外說一下Task.Yield()這個Awaiter，他的行為是捕捉同步上下文，如果有，則會放到同步上下文中執(zhí)行，如果沒有，則會放到線程池中執(zhí)行。在窗體程序中，有時候你打開一個模態(tài)對話框，會導(dǎo)致主窗體部分的動畫沒有反應(yīng)，在模態(tài)對話框關(guān)閉之后，才會反應(yīng)。原因是模態(tài)對話框阻塞了主窗體的消息