haskell - 超时时如何重试阻塞IO Action?

标签 haskell io retry-logic

如何处理 Haskell 中的阻塞 IO 操作?我如何将这个 IO 操作放在一个范围内并从另一个方法管理这个范围?如果达到超时,我将重新调用此方法。通常在其他语言中,如果我没有在可配置的时间内得到结果,我可能会把它放在一个单独的线程中并 abort 它。 (定时器是外部的。)

在我的例子中:我有很多次重试,假设我想执行一个超时的IO 操作。当且仅当 retries 的次数大于 0 时,我如何将 IO 操作置于超时范围内,以便在超时到期后将其重新调用。

基本上:给定我们的 IO 操作,例如 ioMethod::IO String(我还没有查看 Haskell 的套接字库),我们假设它是黑色的盒子,

module Retry where

import IOExternal(ioMethod)

retryFunc :: Int -> IO String
retryFunc retries=do
            msg<-retry 5 100 IOExternal 
            return msg

retry :: Int -> Int -> IOExternal -> IO String
retry retries timeout ioMethod = go retries timeout "" where
        go 0       timeout ioMethod  msg =
                    if msg=="" then return "Max Retries reached" 
                               else return msg

        go retries timeout ioMethod  msg counter
               = gogo retries timeout counter msg  where
                     gogo retries timeout 0 msg = return ""
                     gogo retries timeout counter msg
                        = ioMethod>>=gogo retries timeout counter-1 

我不知道如何为最后一个条件/线建模。

P.S 我还不熟悉 Haskell 中的线程(这里是初学者),我确实认为超时作用域应该在不同的线程中执行,不知何故我需要从我的主线程中检查它程序,然后调用它(如果重试次数>0)或结束 main 方法。

最佳答案

您可以使用 timeout为任何阻塞调用添加超时,并为重试添加简单的递归:

retry :: Int -> Int -> IO a -> IO (Maybe a)
retry 0 _ _ = return Nothing
retry numRetries microseconds action = do
    result <- timeout microseconds action
    case result of
        Nothing -> retry (numRetries-1) microseconds action
        Just a  -> return (Just a)

尽管如此,请务必阅读有关 FFI 内容的注意事项的文档。

关于haskell - 超时时如何重试阻塞IO Action?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/51982526/

相关文章:

haskell - 终止进程时捕获输出

java - DataInputStream 和 OutputStream 写入/读取带长度的字符串

haskell - 为什么 Haskell 不能正确排序这些 IO 操作?

php - 在 PHP 中读取原始 I/O 流的替代方法

java - System.out 关闭了吗?我可以重新打开它吗?

go - 如何模拟第二次尝试 http 调用?

c# - 无法使 Polly 超时策略覆盖 HttpClient 默认超时

c# - 使用 Polly 重试之前检查响应的字符串内容

haskell - 如何轻松地序列化小端 POD?

performance - Repa 3 性能和正确使用 'now'