問題，簡短：
在一個async{...}運算式中，在一個try-finally運算式中，如何do! ... |> Async.AwaitTask在finally塊中使用？
問題，長；失敗的片段：
在等待一系列嵌套的異步任務時，我無法匯總所有例外。
我的設計意圖是每個任務最終都會等待其前一個任務，我希望 Task-Parallel-Library 使用 AggregateException 來組合所有觀察到的例外。
每個異步/任務都可能拋出例外；以下最小示例鏈接/嵌套兩個異步任務，每個任務都拋出例外：
async {
let actionBefore =
async {
printfn "doing sth before..."
failwith "! fail during sth before"
}
|> Async.StartAsTask
printfn "doing sth now..."
failwith "! fail during sth now"
do! actionBefore |> Async.AwaitTask
}
|> Async.StartAsTask
|> Async.AwaitTask
|> Async.RunSynchronously
我的問題是，在不更改開始和等待順序的情況下，如何添加 try-catch- 或 try-finally- 塊，以便最終的 Async.AwaitTask 報告這兩個例外？
我正在使用 F# 版本 5。
uj5u.com熱心網友回復：
現有答案顯示了關鍵技巧，即使用Task.WhenAll- 與其他選項不同，它等待所有任務并聚合所有例外。補充一點，我認為你必須在這里混合任務和異步是令人困惑的。執行此操作的普通 F# 方法是使用Async.StartChild，但只要第一次計算失敗，就會失敗：
async {
let! t1 = Async.StartChild <| async {
printfn "doing sth before..."
failwith "! fail during sth before" }
let! t2 = Async.StartChild <| async {
printfn "doing sth now..."
failwith "! fail during sth now" }
let! r1 = t1
let! r2 = t2
return r1, r2 }
|> Async.RunSynchronously
沒有Async.WhenAll，但您可以使用Task.WhenAll. 這是一個更簡單的版本，只有兩個引數：
module Async =
let WhenBoth(a1, a2) = async {
let r1 = a1 |> Async.StartAsTask
let r2 = a2 |> Async.StartAsTask
let! _ = System.Threading.Tasks.Task.WhenAll(r1, r2) |> Async.AwaitTask
return r1.Result, r2.Result }
這樣，您可以以相當干凈的方式撰寫您最初想要的內容，只需使用async：
async {
let! t1 = Async.StartChild <| async {
printfn "doing sth before..."
failwith "! fail during sth before" }
let! t2 = Async.StartChild <| async {
printfn "doing sth now..."
failwith "! fail during sth now" }
return! Async.WhenBoth(t1, t2) }
|> Async.RunSynchronously
uj5u.com熱心網友回復：
我不是異步/任務方面的專家，但我認為這里的主要問題是do! actionBefore |> Async.AwaitTask永遠無法執行，因此無法捕獲其例外。
相反，我建議您將每個操作作為單獨的任務開始，然后使用Task.WhenAll來等待它們：
async {
let actionBefore =
async {
printfn "doing sth before..."
failwith "! fail during sth before"
}
|> Async.StartAsTask
let actionNow =
async {
printfn "doing sth now..."
failwith "! fail during sth now"
}
|> Async.StartAsTask
do! Task.WhenAll(actionBefore, actionNow)
|> Async.AwaitTask
|> Async.Ignore
}
|> Async.StartAsTask
|> Async.AwaitTask
|> Async.RunSynchronously
這導致AggregateException包含兩個內部例外的 ，這就是我認為你想要的。
請注意，async在這種情況下您不需要外部，因此我認為以下版本更簡單：
let actionBefore =
async {
printfn "doing sth before..."
failwith "! fail during sth before"
}
|> Async.StartAsTask
let actionNow =
async {
printfn "doing sth now..."
failwith "! fail during sth now"
}
|> Async.StartAsTask
Task.WhenAll(actionBefore, actionNow)
|> Async.AwaitTask
|> Async.RunSynchronously
|> ignore
轉載請註明出處，本文鏈接：https://www.uj5u.com/yidong/345418.html