Control.Concurrent.Worker

Documentation

data Worker m

Constructors

Worker

Fields

• workerChan :: Chan (Async (), m ())
• workerTask :: MVar (Async ())

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 ()) -> (m () -> m ()) -> IO (Worker m)

Create new worker

workerAlive :: Worker m -> IO Bool

Check whether worker alive

workerDone :: Worker m -> IO Bool

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

stopWorker :: Worker m -> IO ()

Close worker channel

joinWorker :: Worker m -> IO ()

Stop worker and wait for it

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

module Control.Concurrent.Async