Struct Barriers 

pub struct Barriers { /* private fields */ }

The barriers a running factory is holding.

Implementations

impl Barriers

pub fn new() -> Self

No barriers held.

pub fn deliver(&self, graph: &RouteGraph, flight: Flight) -> Option<Delivery>

Offers a flight to whichever barrier guards its destination.

Returns None when the destination declares no join, which is the common case and means the flight should simply be run.

Panics

Never; the lock is not held across a call out.

pub fn abandon_unreachable( &self, graph: &RouteGraph, live_agents: &BTreeSet<AgentName>, ) -> Vec<Abandoned>

Gives up every barrier that no live run could still satisfy.

live_agents is who is currently running or queued to run. A barrier is dead when none of its missing upstreams can be reached from any of them — at which point waiting is not patience, it is a hang.

pub fn waiting(&self) -> Vec<(BarrierKey, Vec<AgentName>)>

Every barrier currently holding work, for reporting.

pub fn count(&self) -> usize

How many barriers are held, for reporting.

Trait Implementations

impl Debug for Barriers

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for Barriers

fn default() -> Self

Returns the “default value” for a type.