Concurrency.OTP.Process

Documentation

data Pid msg

Identificator of process accepted messages of type msg

Instances

IsProcess a (Pid a)

Eq (Pid a)

Show (Pid a)

data Process msg a

Process computation monad

Instances

Monad (Process msg)

Functor (Process msg)

Applicative (Process msg)

MonadThrow (Process msg)

MonadCatch (Process msg)

MonadIO (Process msg)

data Reason

Process termination reason

Constructors

Normal

Caused when process terminate on end of computation or call exit function

Aborted

Caused when process terminate from another process by terminate function

Error String

Caused when process terminate abnormal way and store exception description

Instances

Eq Reason

Show Reason

class IsProcess a p | p -> a where

Methods

getPid :: p -> Pid a

Instances

IsProcess a (Pid a)

data LinkId

Id of subscription on process termination.

Instances

Eq LinkId

Ord LinkId

spawn :: Process msg () -> IO (Pid msg)

Spawn new process in own thread

linkIO :: IsProcess msg p => p -> (Reason -> IO ()) -> IO LinkId

Register callback, which will be called on process termination and return subscription id. If process has died already, callback will be called immediatly.

unlinkIO :: IsProcess msg p => p -> LinkId -> IO ()

Remove termination callback by LinkId

withLinkIO :: IsProcess msg p => p -> (Reason -> IO ()) -> (LinkId -> IO a) -> IO a

Run action in under link bracket.

withLinkIO_ :: IsProcess msg p => p -> (Reason -> IO ()) -> IO a -> IO a

link :: IsProcess msg p => p -> Process msg LinkId

Link current process with another process p. Current process will be terminated, if process p will be terminated abnormal.

send :: Pid msg -> msg -> Process a ()

Send messages from one process to another

sendIO :: Pid msg -> msg -> IO ()

Asynchronious send messages of type msg to process

receive :: MonadProcess msg m => m msg

Get message from process mailbox. Blocked, if mailbox is empty, until message will be received.

receiveWithTimeout :: MonadProcess msg m => Maybe Int -> m (Maybe msg)

Get message from process mailbox with timeout in milliseconds. Blocked, if mailbox is empty, until message will be received or timeout will be expired.

self :: MonadProcess msg m => m (Pid msg)

Return pid of current process

exit :: MonadProcess msg m => m ()

Terminate current process with Normal reason.

terminate :: IsProcess msg p => p -> IO ()

Terminate process p

isAlive :: IsProcess msg p => p -> IO Bool

Check what process p is alive

wait :: IsProcess msg p => p -> IO ()

Block current execution thread until process is alive.

liftIO :: MonadIO m => forall a. IO a -> m a

Lift a computation from the IO monad.