Haskell: Выполнение действия ввода-вывода только в том случае, если прошло определенное время с момента последнего его выполнения.

Question

У меня есть медиа-поток с соответствующим именованным каналом. Программа считывает данные из каналов и обрабатывает кадры с помощью processFrame.

module Main where 
import Codec.FFmpeg 
import Codec.FFmpeg.Decode 
import Control.Monad.Except (runExceptT) 

main :: IO() 
main = do 
    initFFmpeg 
    -- get IO reader 
    eResult <- runExceptT $ frameReader avPixFmtRgb24 (File "pipe") 
    case eResult of 
     Left err -> do print "couldn't establish frameReader\n" 
         print err 
     Right (getMaybeFrame, cleanup) -> do 
      -- read and process frames until av_read_frame returns no frames 
      loopWhileTrue (getAndProcessFrame getMaybeFrame) 
      cleanup 
      where 
      loopWhileTrue f = do result <- f 
           case result of 
            True -> loopWhileTrue f 
            False -> return() 
     where 
     getAndProcessFrame gMF = do 
      maybeFrame <- gMF 
      case maybeFrame of 
       Just frame -> do tc <- timeCondition 
           if tc 
           then do processFrame frame 
           else return() 
           return True 
       Nothing -> return False 
     timeCondition = return True 

processFrame :: AVFrame -> IO() 
processFrame frame = do isKeyFrame <- getKeyFrame frame 
         if isKeyFrame 
         then do pts <- getPts frame 
           print pts 
         else return() 

мне нужно выполнить processFrame только один раз в минуту, минуя все остальные кадры.

Этот код не имеет надлежащего времени, только timeCondition заглушки. Я планировал написать правильную функцию timeCondition, которая возвращает True, когда определенное время прошло с последних processFrame, в противном случае False. Но это выглядит слишком настойчивым, и неясно, как использовать Monads/MVars для этого. Каков правильный способ разработки такой программы в Haskell?

Answer 1

Возьмите отметку времени, когда шаг обработки завершится с getCurrentTime и проденьте его обратно через ваш цикл, тогда timeCondition - это всего лишь некоторые математические значения времени.

import Data.Time.Clock 

-- | Returns `True` when 60 seconds have passed from the given value. 
-- Not respectful of leap seconds. 
isAMinuteSince :: UTCTime -> IO Bool 
isAMinuteSince timestamp = do 
    now <- getCurrentTime 
    return $ diffUTCTime now timestamp >= 60