Returns the number of delegates required to respond to the number of pending futures
Defines the nature of an actor pool.
Basic decrement as a percentage of the current pool capacity
Filter performs steady incremental growth using only the basic ramp-up subfilter
Basic incremental growth as a percentage of the current pool capacity
Constrains the pool capacity to a bounded range
CyclicIterator is a round-robin style InfiniteIterator that cycles the supplied List.
A default implementation of a pool, on each message to route,
A Dispatcher is a trait whose purpose is to route incoming messages to actors.
The basic filter trait that composes ramp-up and and back-off subfiltering.
Ensures a fixed number of delegates in the pool
An Iterator that is either always empty or yields an infinite number of Ts.
Listeners is a generic trait to implement listening capability on an Actor.
A LoadBalancer is a specialized kind of Dispatcher, that is supplied an InfiniteIterator of targets to dispatch incoming messages to.
Returns the number of delegates required to manage the current message backlogs
Returns the set of delegates that occur sequentially 'after' the last delegate from the previous selection
This filter tracks the average pressure over the lifetime of the pool (or since last reset) and will begin to reduce capacity once this value drops below the provided threshold.
This InfiniteIterator always returns the Actor that has the currently smallest mailbox useful for work-stealing.
Returns the set of delegates with the least amount of message backlog.
An UntypedDispatcher is an abstract class whose purpose is to route incoming messages to actors.
A UntypedLoadBalancer is a specialized kind of UntypedDispatcher, that is supplied an InfiniteIterator of targets to dispatch incoming messages to.