Control.Concurrent.Threaded

Documentation

data ThreadedInternal incoming outgoing

Constructors

ThreadedInternal

Fields

• thread :: Async ()

  The process's execution thread

• outputRelay :: Async ()

  The thread that relays the process's output to the main output

• threadInput :: TChanRW Read incoming

  The process's isolated input

• threadOutput :: TChanRW Write outgoing

  The process's isolated output

threaded

Arguments

:: Ord k

=> Show k

=> MonadIO m

=> MonadBaseControl IO m stM

=> Extractable stM

=> TChanRW Write (k, input)

Incoming messages, identified by thread k

-> (TChanRW Read input -> TChanRW Write output -> m ())

Process to spark in a new thread. When m () returns, the thread is considered "dead", and is internally cleaned up.

-> m (Async (), TChanRW Read (k, output))

Segregates concurrently operating threads by some key type k. Returns the thread that processes all other threads (this function is non-blocking), and the channel that dispenses the outputs from each thread.