指定無限循環的毫秒速度

Question

我的主函數有一個無限循環，我想每100毫秒執行一次循環。我知道這是通過一些並行或並行的方法完成的，但我從來沒有做過這樣的事情，甚至不知道從哪裏開始。你將如何實現這樣的功能？

Answer 1

假設你的循環體需要可以忽略不計的時候，只需要使用threadDelay從Control.Concurrent：

import Control.Concurrent 

main = forever $ do 
    mainBody 
    threadDelay (100*1000) -- value in microseconds 

更新：爲了解決您的循環體的時候，用這個：

import Data.Time.Clock 
import Control.Concurrent 
import Control.Monad 

mainBody :: IO() 
mainBody = putStrLn "hi" 

main = forever $ do 
    start <- getCurrentTime 
    mainBody 
    end <- getCurrentTime 
    let diff = diffUTCTime end start 
     usecs = floor (toRational diff * 1000000) :: Int 
     delay = 100*1000 - usecs 
    if delay > 0 
    then threadDelay delay 
    else return() 

Answer 2

您可以使用sleep在每次迭代結束時暫停循環100毫秒。 https://www.haskell.org/hoogle/?q=sleep

Answer 3

Haskell的主題重量輕，所以快速解決方案是在每個週期進行分岔。因此，您最終將使用主線程作爲工作線程的管理器，這可以確保每100個微工生成一個工人。

import Control.Concurrent 

main = 
    forever $ do 
    forkIO $ loopCycle 
    threadDelay $ 100 * 10^3 

如果你關心的異常不迷路，並在主線程中得到重新拋出相反，我建議考慮看看the "slave-thread" package。其實，我建議使用這個軟件包，而不是forkIO和默認的兄弟，但是我是作者，所以我可能是主觀的。

另請注意，上述解決方案可能會導致工作線程累積，以防loopCycle需要比100微秒更長的執行時間。爲了防止出現這種情況，您可以在經理線程中實施策略，以確保活動員工的數量有限。以下是如何實現這樣一個策略：

-- From the "SafeSemaphore" package 
import qualified Control.Concurrent.SSem as Sem 

main = 
    manager 12 (100 * 10^3) $ putStrLn "Implement me!" 

manager :: Int -> Int -> IO() -> IO() 
manager limit delay worker = 
    do 
    sem <- Sem.new limit 
    forever $ do 
     forkIO $ Sem.withSem sem $ worker 
     threadDelay delay