Struct WorkQueue 

pub struct WorkQueue<A: Address, T, WorkerRoute: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = T>>, ReplyRoute: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = WorkQueueOutcome<T>>>> { /* private fields */ }

Bounded FIFO admission and worker-availability behavior.

Availability is a one-dispatch capability. It immediately consumes the oldest waiting value or joins a unique FIFO of available workers. Submission consumes the oldest worker or enters the bounded FIFO; at capacity it returns the owned value. Duplicate availability and withdrawal are idempotent. Initialization is empty, no actors are created, and the host never terminates by policy. FIFO selection and bounded admission are Bombay policy. Worker execution, mailbox admission, and physical backpressure are runtime responsibilities. Naming its protocol requires only typed routes; running the queue requires cloneable, comparable worker routes for state inspection and duplicate availability checks. No transition has a semantic panic condition.

Implementations

impl<A, T, WorkerRoute, ReplyRoute> WorkQueue<A, T, WorkerRoute, ReplyRoute>

where A: Address, WorkerRoute: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = T>> + Clone + PartialEq, ReplyRoute: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = WorkQueueOutcome<T>>> + Clone,

pub fn new(capacity: usize) -> Self

Construct an empty queue with explicit waiting capacity.

pub fn state(&self) -> WorkQueueState<WorkerRoute>

Return complete observable queue state.

Trait Implementations

impl<A, T, WorkerRoute, ReplyRoute> Behavior for WorkQueue<A, T, WorkerRoute, ReplyRoute>

where A: Address, WorkerRoute: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = T>> + Clone + PartialEq, ReplyRoute: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = WorkQueueOutcome<T>>> + Clone, WorkerRoute::Sends: SendsFor<User<A, WorkQueueMessage<T, WorkerRoute, ReplyRoute>>>, ReplyRoute::Sends: SendsFor<User<A, WorkQueueMessage<T, WorkerRoute, ReplyRoute>>>,

type Protocol = WorkQueue<A, T, WorkerRoute, ReplyRoute>

Stable public communication identity owned by this actor template.

type Event = User<A, <<WorkQueue<A, T, WorkerRoute, ReplyRoute> as Behavior>::Protocol as Protocol>::Msg>

type Sends = WorkQueueSends<<WorkerRoute as DeliveryRoute>::Sends, <ReplyRoute as DeliveryRoute>::Sends>

type Ph = Never

type Error = Never

type Birth = NoBirths

fn transition( &mut self, _: ActiveTurn, event: Self::Event, ) -> BehaviorActed<Self>

Fold exactly one event into explicit actions and the next behavior.

fn init( &mut self, _turn: InitializationTurn, ) -> Result<Actions<<Self::Protocol as Protocol>::Addr, Self::Ph, Self::Sends, Self::Birth>, Self::Error>

where Self: Sized,

Produce initialization actions before the first event is accepted.

fn layer<L>(self, layer: L) -> <L as BehaviorLayer<Self>>::Output

where Self: Sized, L: BehaviorLayer<Self>,

Apply one statically dispatched construction layer.

impl<A, T, WorkerRoute, ReplyRoute> BehaviorBase for WorkQueue<A, T, WorkerRoute, ReplyRoute>

where A: Address, WorkerRoute: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = T>>, ReplyRoute: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = WorkQueueOutcome<T>>>,

type Base = WorkQueue<A, T, WorkerRoute, ReplyRoute>

fn base(&self) -> &Self

impl<A, T, WorkerRoute, ReplyRoute> Protocol for WorkQueue<A, T, WorkerRoute, ReplyRoute>

where A: Address, WorkerRoute: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = T>>, ReplyRoute: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = WorkQueueOutcome<T>>>,

type Addr = A

type Msg = WorkQueueMessage<T, WorkerRoute, ReplyRoute>