tính toán không đồng bộ không bắt được OperationCancelledException

Question

Tôi đang cố thực hiện yêu cầu web không đồng bộ cho URL sẽ trả về nếu yêu cầu mất quá nhiều thời gian. Tôi đang sử dụng F # không đồng bộ công việc và thư viện System.Net.Http để làm điều này.

Tuy nhiên, tôi không thể nắm bắt được Task/OperationCancelledExceptions được tăng lên bởi thư viện System.Net.Http trong luồng công việc async. Thay vào đó, các ngoại lệ xảy ra ở phương pháp Async.RunSynchronously, như bạn có thể thấy trong stack trace này:

> System.OperationCanceledException: The operation was canceled. at 
> Microsoft.FSharp.Control.AsyncBuilderImpl.commit[a](Result`1 res) 
> at 
> Microsoft.FSharp.Control.CancellationTokenOps.RunSynchronously[a](CancellationToken 
> token, FSharpAsync`1 computation, FSharpOption`1 timeout) at 
> Microsoft.FSharp.Control.FSharpAsync.RunSynchronously[T](FSharpAsync`1 
> computation, FSharpOption`1 timeout, FSharpOption`1 cancellationToken) 
> at <StartupCode$FSI_0004>.$FSI_0004.main@() 

Mã:

#r "System.Net.Http" 

open System.Net.Http 
open System 

let readGoogle() = async { 
    try 
     let request = new HttpRequestMessage(HttpMethod.Get, "https://google.co.uk") 
     let client = new HttpClient() 
     client.Timeout <- TimeSpan.FromSeconds(0.01) //intentionally low to always fail in this example 
     let! response = client.SendAsync(request, HttpCompletionOption.ResponseContentRead) |> Async.AwaitTask 
     return Some response 
    with 
     | ex -> 
      //is never called 
      printfn "TIMED OUT" 
      return None 
} 

//exception is raised here 
readGoogle() 
    |> Async.RunSynchronously 
    |> ignore 

Answer 1

hủy luôn khác nhau từ lỗi. Trong trường hợp của bạn, bạn có thể thay đổi hành vi mặc định của AwaitTask mà gọi "hủy tiếp tục" nếu nhiệm vụ bị hủy và xử lý theo cách khác:

let readGoogle() = async { 
    try 
     let request = new HttpRequestMessage(HttpMethod.Get, "https://google.co.uk") 
     let client = new HttpClient() 
     client.Timeout <- TimeSpan.FromSeconds(0.01) //intentionally low to always fail in this example 
     return! ( 
      let t = client.SendAsync(request, HttpCompletionOption.ResponseContentRead) 
      Async.FromContinuations(fun (s, e, _) -> 
       t.ContinueWith(fun (t: Task<_>) -> 
        // if task is cancelled treat it as timeout and process on success path 
        if t.IsCanceled then s(None) 
        elif t.IsFaulted then e(t.Exception) 
        else s(Some t.Result) 
       ) 
       |> ignore 
      ) 
     ) 
    with 
     | ex -> 
      //is never called 
      printfn "TIMED OUT" 
      return None 
}