pod concurrent
Utilities for concurrent programming
Mixins
| ActorContext | ActorContext is standardized thread local state stored in by "cx" key |
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
| NotCompleteErr | Raised when attempting to access results of a future in the pending state. |
| QueueOverflowErr | QueueOverflowErr is raised by a Future for messages sent to actor that has exceeded the max queue size. |