multithreading - 从异步方法访问记录器对象时死锁同步运行

Question

以下代码正在尝试做一些工作，如果出现错误，则重试。还有一个错误回调，它调用一个将错误记录到控制台的函数。

执行时，错误仅记录到控制台一次，当程序暂停时，主线程在 retryErrorForever 中被阻塞。并且工作线程在获取 log 时被阻塞.

但为什么？

module Program

type MyLogger(loggerName: string) =
    member __.Warn fmt =
        Printf.kprintf (printfn "%s: %s" loggerName) fmt

let log = MyLogger("Logger")

let retryErrorForever errorCallback retryTimeout work =
    let rec loop () = async {
        let! result = work

        match result with
        | Error e ->
            errorCallback e
            do! Async.Sleep retryTimeout
            return! loop()
        | Ok x -> return Ok x
    }

    loop ()

let retryWorkUntilOk logError timeout (work: unit -> Result<string, string>) =
    let workflow = async {
        return work ()
    }

    let result =
        retryErrorForever logError timeout workflow
        |> Async.RunSynchronously

    match result with
    | Ok x -> x
    | Error e -> failwith <| sprintf "Cannot doWork: %s" e

let logError error =
    log.Warn "%s" error

let doWork work =
    retryWorkUntilOk logError 1000 work

let errorOnly () : Result<string, string> =
    Error "You have no power here"

let result = doWork errorOnly

[<EntryPoint>]
let main _ =
    printfn "%A" result
    0

Answer 1

当以交互方式运行时，这个程序完全按照它应该做的:每秒钟打印一次“You have no power here”。

但是，如果您正在编译它并运行可执行文件，则会出现一个问题:行 let result = ...在 main 之前在程序集初始化时求值甚至运行，整个程序内容都在这段时间内执行。但是，程序集初始化应该是同步的。它可以启动异步任务，但在静态初始化完成之前它们不会完成 - 并且您的程序编写方式，静态初始化正在等待这些异步任务完成。所以你会陷入僵局。

要解决这个问题，只需让整个过程从 main 开始运行, 而不是在静态初始化期间。这可以通过制作 result 来完成。一个函数，然后从 main 调用它:

let result() = doWork errorOnly

[<EntryPoint>]
let main _ =
    printfn "%A" <| result()
    0