module Unfork.Async.FireAndForget.IO
(
unforkAsyncIO_,
)
where
import Unfork.Async.Core
import Prelude (IO, pure)
import Control.Monad.STM (atomically)
unforkAsyncIO_ ::
(task -> IO result)
-> ((task -> IO ()) -> IO conclusion)
-> IO conclusion
unforkAsyncIO_ :: (task -> IO result)
-> ((task -> IO ()) -> IO conclusion) -> IO conclusion
unforkAsyncIO_ task -> IO result
action =
Unfork task (IO ())
-> ((task -> IO ()) -> IO conclusion) -> IO conclusion
forall a c b. Unfork a c -> ((a -> c) -> IO b) -> IO b
unforkAsync Unfork :: forall a c q. (Ctx q -> a -> c) -> (q -> IO ()) -> Unfork a c
Unfork{ Ctx task -> task -> IO ()
forall q. Ctx q -> q -> IO ()
unforkedAction :: Ctx task -> task -> IO ()
unforkedAction :: forall q. Ctx q -> q -> IO ()
unforkedAction, task -> IO ()
executeOneTask :: task -> IO ()
executeOneTask :: task -> IO ()
executeOneTask }
where
unforkedAction :: Ctx q -> q -> IO ()
unforkedAction Ctx q
ctx q
arg = STM () -> IO ()
forall a. STM a -> IO a
atomically (Ctx q -> q -> STM ()
forall q. Ctx q -> q -> STM ()
enqueue Ctx q
ctx q
arg)
executeOneTask :: task -> IO ()
executeOneTask task
a = do{ result
_ <- task -> IO result
action task
a; () -> IO ()
forall (f :: * -> *) a. Applicative f => a -> f a
pure () }