Struct PolicyExecutor

pub struct PolicyExecutor<P, L> {
    pub schedule: Schedule<L>,
    pub policy: P,
    pub trace: Trace<Idx>,
}

An executor for a task schedule

Fields

schedule: Schedule<L>

policy: P

trace: Trace<Idx>

Implementations

impl<P, L> PolicyExecutor<P, L>

where L: 'static,

pub fn custom(schedule: Schedule<L>, policy: P) -> Self

Creates a new executor with a custom policy.

impl<L> PolicyExecutor<Fifo, L>

where L: 'static,

pub fn fifo(schedule: Schedule<L>) -> Self

Creates a new executor with a FIFO policy.

pub fn max_concurrent(self, limit: Option<usize>) -> Self

impl<L> PolicyExecutor<Priority, L>

where L: Ord + 'static,

pub fn priority(schedule: Schedule<L>) -> Self

Creates a new executor with a priority policy.

The priority is given by the task label.

pub fn max_concurrent(self, limit: Option<usize>) -> Self

impl<P, L> PolicyExecutor<P, L>

where P: Policy<L>, L: 'static,

pub async fn run(&mut self)

Runs the tasks in the graph

Trait Implementations

impl<P: Debug, L: Debug> Debug for PolicyExecutor<P, L>

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

Formats the value using the given formatter.