1. 程式人生 > >[譯]async/await中使用阻塞式程式碼導致死鎖

[譯]async/await中使用阻塞式程式碼導致死鎖

    這篇博文主要是講解在async/await中使用阻塞式程式碼導致死鎖的問題,以及如何避免出現這種死鎖。內容主要是從作者Stephen Cleary的兩篇博文中翻譯過來.

原文1Don'tBlock on Async Code

原文2why the AspNetSynchronizationContext was removed

 

示例程式碼:async_await中使用阻塞式程式碼導致死鎖.rar

 

一、async/await 非同步程式碼執行流程

        

async/await是在.NET4.5版本引入的關鍵字,讓開發者可以更加輕鬆的建立非同步方法。

         我們從下圖來認識async/await的執行流程:

 

二、在非同步程式碼中阻塞,導致死鎖的示例

UI 示例

         單擊一個按鈕,將發起一個REST遠端請求並且將結果顯示到textbox控制元件上。(這是一個Windows Forms程式,同樣也適用於其他任何UI應用程式)

// My "library" method.

public static async Task<JObject> GetJsonAsync(Uri uri)

{

  using (var client = new HttpClient())

  {

    var jsonString = await client.GetStringAsync(uri);

    return JObject.Parse(jsonString);

  }

}

 

// My "top-level" method.

public void Button1_Click(...)

{

  var jsonTask = GetJsonAsync(...);

  textBox1.Text = jsonTask.Result;

}

         類庫方法GetJsonAsync發起REST遠端請求並且將結果解析為JSON返回。Button1_Click方法呼叫Task .Result阻塞等待GetJsonAsync處理完畢並顯示結果

         這段程式碼會死鎖。

ASP.NET 示例

         在類庫方法GetJsonAsync中發起一個REST遠端請求,這次這個GetJsonAsyncASP.NET context中被呼叫。(示例是Web API專案,同樣適用於任何一個ASP.NET應用程式 - 注:非ASP.NET Core應用)

// My "library" method.

public static async Task<JObject> GetJsonAsync(Uri uri)

{

  using (var client = new HttpClient())

  {

    var jsonString = await client.GetStringAsync(uri);

    return JObject.Parse(jsonString);

  }

}

 

// My "top-level" method.

public class MyController : ApiController

{

  public string Get()

  {

    var jsonTask = GetJsonAsync(...);

    return jsonTask.Result.ToString();

  }

}

         這段程式碼也會死鎖。與UI示例是同一個原因。

 

三、是什麼原因導致的死鎖呢?

         await一個Task後,在恢復繼續執行時,會試圖進入await之前的context

         第一個示例中,這個contextUI context(任何UI應用,除了控制檯應用)。在第二個示例中,這個contextASP.NET request context

         另一個需要注意的點:ASP.NET request context 沒有繫結到特定的執行緒上(像UI context一樣),但是request context同一時刻只允許被繫結到一個執行緒上。我曾經在MSDN上有發表過關於SynchronzationContext的文章.

         死鎖是怎麼發生的呢?我們從top-level方法開始(UIButton1_Click方法或ASP.NETMyContoller.Get方法)

1.         top-level方法呼叫GetJsonAsync(在UI/ASP.NET context中)。

2.         GetJsonAsync通過HttpClient.GetStringAsync發起REST遠端請求(在UI/ASP.NET context中)。

3.         GetStringAsync返回一個未完成Task,標識REST遠端請求還未處理完

4.         GetJsonAsync方法中await GetStringAsync返回的未完成Task。等Task執行完畢,

會重新捕獲等待之前的context並使用它繼續執行GetJsonAsync

5.         GetJsonAsyncawait後,攜帶context的執行緒會跳出GetJsonAsync方法,繼續執行後面的程式碼。並在jsonTask.Result發生阻塞。此時攜帶context的執行緒被阻塞了。

6.         最終,REST請求處理完,GetStringAsync返回的Task處理完成。

7.         GetJsonAsync方法準備繼續執行,並且等待context可用,以便在context中執行。

8.         發生context死鎖。在top-level方法中已經阻塞了攜帶context的執行緒,等待GetJsonAsync返回的Task完成。而此時,GetJsonAsync方法正在等待context被釋放,以便在context中繼續執行。

 

四、防止死鎖

         這裡有三個最佳實踐來避免這種死鎖(更詳細傳送門)。

1.         在你的”library”非同步方法中,返回未完成Task時都呼叫ConfigureAwait(false)

2.         始終使用 Async不要混合阻塞式程式碼和非同步程式碼

3.         ASP.NET 升級為ASP.NET Core。在ASP.NET Core框架中,已經移除SynchronizationContext

按照第一條最佳實踐,”library”中的非同步方法修改如下:

public static async Task<JObject> GetJsonAsync(Uri uri)

{

  using (var client = new HttpClient())

  {

    var jsonString = await client.GetStringAsync(uri).ConfigureAwait(false);

    return JObject.Parse(jsonString);

  }

}

ConfigureAwait(continueOnCapturedContext: false)continueOnCapturedContext引數表示是否嘗試將延續任務封送回原始上下文。

ConfigureAwait(false)改變了GetJsonAsync的延續行為,使它不用在原來的context中恢復。GetJsonAsync將直接線上程池執行緒中恢復,這使得GetJsonAsync能完成任務,並且無需重新進入原來的context

 

         按照第二條最佳實踐。修改”top-level”方法如下:

public async void Button1_Click(...)

{

  var json = await GetJsonAsync(...);

  textBox1.Text = json;

}

 

public class MyController : ApiController

{

  public async Task<string> Get()

  {

    var json = await GetJsonAsync(...);

    return json.ToString();

  }

}

         這樣修改,改變了top-level方法的阻塞行為。所有的等待都是非同步等待,這樣context就不會被阻塞。

其他非同步等待指導原則:

執行以下操作

不要使用以下方式

使用以下方式

建立Task

Task constructor

Task.Run or TaskFactory.StartNew

檢索後臺任務的結果

Task.Wait Task.Result

await

等待任何任務完成

Task.WaitAny

await Task.WhenAny

檢索多個任務的結果

Task.WaitAll

await Task.WhenAll

等待一段時間

Thread.Sleep

await Task.Delay

 

五、在ASP.NET Core框架中,已經移除SynchronizationContext

為什麼AspNetSynchronizationContextASP.NET Core中被移除。儘管我不知道ASP.NET團隊內部是什麼觀點,但我認為的觀點是兩個:效能和簡單。

效能方面:

在沒有SynchronizationContextASP.NET Core中,當一個async/await非同步處理恢復執行時,會從執行緒池中獲取一個執行緒並且執行繼續操作。

1.         避免了把操作排隊到request context佇列(request context同一時刻只允許被繫結到一個執行緒上)

2.         避免了因為攜帶 request context 的執行緒被阻塞而發生“死鎖”

3.         不需要重新進入request context(重新進入request context涉及到很多內部作業任務,例如:設定HttpContext.Current和當前執行緒的身份標識(identity)和語言(culture))

簡單化:

舊版本ASP.NETSynchronizationContext工作的很好,但是也存在棘手的問題,特別是在身份管理方面(參考:Thread.CurrentPrincipal VS HttpContext.Current.User)

 

六、async/await避免阻塞式死鎖最佳實踐

1.         在你的“library”非同步方法中,返回未完成Task時都呼叫ConfigureAwait(false),標識不需要將延續任務封送回原始上下文。

儘管在ASP.NET Core中,不用再呼叫ConfigureAwait(false)來防止死鎖。但由於你提供的“類庫”可能被用於UI 應用(egwinformwpf等)、舊版本ASP.NET應用、其他還存在context的應用。

2.         更好的解決方案是“始終使用 async,不要混合阻塞式程式碼和非同步程式碼”。

因為當你在非同步程式碼中阻塞程式,將失去非同步程式碼帶來的所有好處。並且非同步程式碼釋放當前執行緒帶來的伸縮性也會失效。

3.         ASP.NET專案升級為ASP.NET Core專案

 

推薦閱讀:

   Async/Await FAQ原文##譯文

   Stephen Cleary 的開源元件:AsyncEx

        Async/Await 非同步程式設計中的最佳做法(原文##譯文

        (xishuai)ASP.NET混合阻塞式程式碼和非同步程式碼,執行緒切換變化