Control.Concurrent.Worker

Documentation

data Worker m

Constructors

Worker

Fields

• workerChan :: Chan (Async (), m ())
• workerWrap :: forall a. m a -> m a
• workerTask :: MVar (Async ())
• workerTouch :: IO ()

data WorkerStopped

Constructors

WorkerStopped

Instances

Show WorkerStopped

Methods

showsPrec :: Int -> WorkerStopped -> ShowS

show :: WorkerStopped -> String

showList :: [WorkerStopped] -> ShowS

Exception WorkerStopped

Methods

toException :: WorkerStopped -> SomeException

fromException :: SomeException -> Maybe WorkerStopped

displayException :: WorkerStopped -> String

startWorker :: MonadIO m => (m () -> IO ()) -> (m () -> m ()) -> (forall a. m a -> m a) -> IO (Worker m)

Create new worker

workerDone :: Worker m -> IO Bool

sendTask :: (MonadCatch m, MonadIO m) => Worker m -> m a -> IO (Async a)

pushTask :: (MonadCatch m, MonadIO m) => Worker m -> m a -> IO (Async a)

restartWorker :: Worker m -> IO ()

stopWorker :: Worker m -> IO ()

syncTask :: (MonadCatch m, MonadIO m) => Worker m -> IO ()

Send empty task and wait until worker run it

inWorkerWith :: (MonadIO m, MonadCatch m, MonadIO n) => (SomeException -> n a) -> Worker m -> m a -> n a

Run action in worker and wait for result

inWorker :: (MonadIO m, MonadCatch m) => Worker m -> m a -> IO a

Run action in worker and wait for result

inWorker_ :: (MonadIO m, MonadCatch m) => Worker m -> m a -> ExceptT SomeException IO a

Run action in worker and wait for result

module Control.Concurrent.Async