以下代码正在尝试做一些工作,如果出现错误,则重试。还有一个错误回调,它调用一个将错误记录到控制台的函数。
执行时,错误仅记录到控制台一次,当程序暂停时,主线程在 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
最佳答案
当以交互方式运行时,这个程序完全按照它应该做的:每秒钟打印一次“You have no power here”。
但是,如果您正在编译它并运行可执行文件,则会出现一个问题:行 let result = ...
在 main
之前在程序集初始化时求值甚至运行,整个程序内容都在这段时间内执行。但是,程序集初始化应该是同步的。它可以启动异步任务,但在静态初始化完成之前它们不会完成 - 并且您的程序编写方式,静态初始化正在等待这些异步任务完成。所以你会陷入僵局。
要解决这个问题,只需让整个过程从 main
开始运行, 而不是在静态初始化期间。这可以通过制作 result
来完成。一个函数,然后从 main
调用它:
let result() = doWork errorOnly
[<EntryPoint>]
let main _ =
printfn "%A" <| result()
0
关于multithreading - 从异步方法访问记录器对象时死锁同步运行,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/47598348/