序列化異步任務和異步繼續

Question

我有很長時間的運行處理，我想在後臺任務中執行。在任務結束時，我想表示它已完成。所以基本上我有兩個異步任務，我想在後臺運行一個接一個。

我在繼續執行此操作，但是繼續操作是在完成初始任務之前開始的。預期的行爲是繼續只在完成初始任務後運行。

下面是一個說明該問題的一些示例代碼：

// Setup task and continuation 
var task = new Task(async() => 
{ 
    DebugLog("TASK Starting"); 
    await Task.Delay(1000);  // actual work here 
    DebugLog("TASK Finishing"); 
}); 

task.ContinueWith(async (x) => 
{ 
    DebugLog("CONTINUATION Starting"); 
    await Task.Delay(100);  // actual work here 
    DebugLog("CONTINUATION Ending"); 
}); 

task.Start(); 

的DEBUGLOG功能：

static void DebugLog(string s, params object[] args) 
{ 
    string tmp = string.Format(s, args); 
    System.Diagnostics.Debug.WriteLine("{0}: {1}", DateTime.Now.ToString("HH:mm:ss.ffff"), tmp); 
} 

預期輸出：

TASK Starting 
TASK Finishing 
CONTINUATION Starting 
CONTINUATION Ending 

實際輸出：

TASK Starting 
CONTINUATION Starting 
CONTINUATION Ending 
TASK Finishing 

同樣，我的問題是爲什麼在完成初始任務之前繼續開始？如何在第一項任務完成後繼續運行？

---

變通辦法＃1

我可以讓上面的代碼工作，如果我做INTIAL任務同步如預期 - 那就是如果我Wait在Task.Delay像這樣：    

var task = new Task(() => 
{ 
    DebugLog("TASK Starting"); 
    Task.Delay(1000).Wait();  // Wait instead of await 
    DebugLog("TASK Finishing"); 
}); 

由於很多原因，使用Wait這樣做很不好。一個原因是它阻塞了線程，這是我想避免的。

---

變通辦法＃2

如果我接任務的創建，並將其移動到它自己的功能，這似乎也工作：

// START task and setup continuation 
var task = Test1(); 
task.ContinueWith(async (x) => 
{ 
    DebugLog("CONTINUATION Starting"); 
    await Task.Delay(100);  // actual work here 
    DebugLog("CONTINUATION Ending"); 
}); 

static public async Task Test1() 
{ 
    DebugLog("TASK Starting"); 
    await Task.Delay(1000);  // actual work here 
    DebugLog("TASK Finishing"); 
} 

信貸的上述方法去到這個有點相關（但不重複）的問題：Use an async callback with Task.ContinueWith

---

解決方法＃2比解決方法＃1更好，如果沒有解釋爲什麼我上面的初始代碼不起作用，我可能會採取這種方法。

Answer 1

由於async lambda被翻譯爲async void下方的方法，它沒有內置的方法來通知任何已完成的代碼，因此您的原始代碼不起作用。所以，你所看到的是async void和async Task之間的差異。這是你應該避免的原因之一async void。也就是說，如果可以使用你的代碼，使用Task.Run而不是Task的構造函數和Start;更自然

var task = Task.Run(async() => 
{ 
    DebugLog("TASK Starting"); 
    await Task.Delay(1000);  // actual work here 
    DebugLog("TASK Finishing"); 
}); 
await task; 
DebugLog("CONTINUATION Starting"); 
await Task.Delay(100);  // actual work here 
DebugLog("CONTINUATION Ending"); 

Task.Run和await工作，async代碼：和使用await而非ContinueWith。

Answer 2

您不應該直接使用Task構造函數來啓動任務，特別是在啓動異步任務時。如果你想卸載工作，在後臺使用Task.Run代爲執行：

var task = Task.Run(async() => 
{ 
    DebugLog("TASK Starting"); 
    await Task.Delay(1000);  // actual work here 
    DebugLog("TASK Finishing"); 
}); 

關於延續，這將是最好只追加它的邏輯lambda表達式的結束。但是，如果你使用ContinueWith堅定你需要使用Unwrap獲得實際的異步任務和儲存，所以你可以處理異常：

task = task.ContinueWith(async (x) => 
{ 
    DebugLog("CONTINUATION Starting"); 
    await Task.Delay(100);  // actual work here 
    DebugLog("CONTINUATION Ending"); 
}).Unwrap(); 

try 
{ 
    await task; 
} 
catch 
{ 
    // handle exceptions 
} 

Answer 3

更改您的代碼

 // Setup task and continuation 
     var t1 = new Task(() => 
     { 
      Console.WriteLine("TASK Starting"); 
      Task.Delay(1000).Wait();  // actual work here 
      Console.WriteLine("TASK Finishing"); 
     }); 

     var t2 = t1.ContinueWith((x) => 
     { 
      Console.WriteLine("C1"); 
      Task.Delay(100).Wait();  // actual work here 
      Console.WriteLine("C2"); 
     }); 

     t1.Start(); 

     // Exception will be swallow without the line below 
     await Task.WhenAll(t1, t2);