pod concurrent

Utilities for concurrent programming

Classes

Actor

Actor is a worker who processes messages asynchronously.

ActorMsg

ActorMsg provides simple immutable tuple to use for actor messages.

ActorPool

Controller for a group of actors which manages their execution using pooled thread resources.

AtomicBool

AtomicBool is used to manage a boolean variable shared between actor/threads with atomic updates.

AtomicInt

AtomicInt is used to manage an integer variable shared between actor/threads with atomic updates.

AtomicRef

AtomicRef is used to manage a object reference shared between actor/threads with atomic updates.

ConcurrentMap

ConcurrentMap is a Fantom wrapper around Java's ConcurrentHashMap.

Future

Future represents the result of an asynchronous computation.

Lock

Lock for synchronization between actors.

Enums

FutureStatus

State of a Future's asynchronous computation

Errs

QueueOverflowErr

QueueOverflowErr is raised by a Future for messages sent to actor that has exceeded the max queue size.