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
| QueueOverflowErr |
QueueOverflowErr is raised by a Future for messages sent to actor that has exceeded the max queue size. |