[Haskell-cafe] Implementing computations with timeout

Einar Karttunen ekarttun at cs.helsinki.fi
Fri Jan 7 09:55:05 EST 2005


Tomasz Zielonka <tomasz.zielonka at gmail.com> writes:
>   import Control.Concurrent (forkIO, threadDelay)
>   import Control.Concurrent.STM
>
>   withTimeout :: Int -> STM a -> IO (Maybe a)
>   withTimeout time fun = do
>       mv <- atomically newEmptyTMVar
>       tid <- forkIO $ do
>           threadDelay time
>           atomically (putTMVar mv ())
>       x <- atomically (fmap Just fun `orElse` (takeTMVar mv >> return Nothing))
>       killThread tid
>       return x

Isn't this buggy if fun just keeps working without throwing an exception
or using retry? I meant wholly inside STM - if we use IO as the
signature then using the TMVar has few advantages over using an MVar.

- Einar Karttunen


More information about the Haskell-Cafe mailing list