Control.Eff.Concurrent.Process.ForkIOScheduler

Implement Erlang style message passing concurrency.

This module contains spawn which handles the Process effects, using TQueues and withAsync.

This aims to be a pragmatic implementation, so even logging is supported.

At the core is a main process that enters schedule and creates all of the internal state stored in TVars to manage processes with message queues.

Documentation

schedule :: HasCallStack => Eff InterruptableProcEff () -> Eff LoggingAndIo ()

This is the main entry point to running a message passing concurrency application. This function takes a Process on top of the SchedulerIO effect for concurrent logging.

defaultMain :: HasCallStack => Eff InterruptableProcEff () -> IO ()

Start the message passing concurrency system then execute a Process on top of SchedulerIO effect. All logging is sent to standard output.

defaultMainWithLogWriter :: HasCallStack => LogWriter IO -> Eff InterruptableProcEff () -> IO ()

Start the message passing concurrency system then execute a Process on top of SchedulerIO effect. All logging is sent to standard output.

type ProcEff = ConsProcess SchedulerIO

The concrete list of Effects of processes compatible with this scheduler. This builds upon SchedulerIO.

type InterruptableProcEff = InterruptableProcess SchedulerIO

The concrete list of the effects, that the Process uses

type SchedulerIO = Reader SchedulerState ': LoggingAndIo

The concrete list of Effects for this scheduler implementation.

type HasSchedulerIO r = (HasCallStack, Lifted IO r, SchedulerIO <:: r)

Type class constraint to indicate that an effect union contains the effects required by every process and the scheduler implementation itself.