Control.Distributed.Process.Internal.Spawn

Documentation

spawn :: NodeId -> Closure (Process ()) -> Process ProcessId

Spawn a process

For more information about Closure, see Control.Distributed.Process.Closure.

See also call.

spawnLink :: NodeId -> Closure (Process ()) -> Process ProcessId

Spawn a process and link to it

Note that this is just the sequential composition of spawn and link. (The Unified semantics that underlies Cloud Haskell does not even support a synchronous link operation)

spawnMonitor :: NodeId -> Closure (Process ()) -> Process (ProcessId, MonitorRef)

Like spawnLink, but monitor the spawned process

call :: Serializable a => Static (SerializableDict a) -> NodeId -> Closure (Process a) -> Process a

Run a process remotely and wait for it to reply

We monitor the remote process: if it dies before it can send a reply, we die too.

For more information about Static, SerializableDict, and Closure, see Control.Distributed.Process.Closure.

See also spawn.

spawnSupervised :: NodeId -> Closure (Process ()) -> Process (ProcessId, MonitorRef)

Spawn a child process, have the child link to the parent and the parent monitor the child

spawnChannel :: forall a. Serializable a => Static (SerializableDict a) -> NodeId -> Closure (ReceivePort a -> Process ()) -> Process (SendPort a)

Spawn a new process, supplying it with a new ReceivePort and return the corresponding SendPort.