Struct aleph_bft::rmc::DoublingDelayScheduler

pub struct DoublingDelayScheduler<T> { /* fields omitted */ }

A basic task scheduler scheduling tasks with an exponential slowdown

A scheduler parameterized by a duration initial_delay. When a task is added to the scheduler it is first scheduled immediately, then it is scheduled indefinitely, where the first delay is initial_delay, and each following delay for that task is two times longer than the previous one.

Implementations

impl<T> DoublingDelayScheduler<T>

pub fn new(initial_delay: Duration) -> Self

Trait Implementations

impl<T: Send + Sync + Clone> TaskScheduler<T> for DoublingDelayScheduler<T>

fn add_task(&mut self, task: T)

fn next_task<'life0, 'async_trait>(
    &'life0 mut self
) -> Pin<Box<dyn Future<Output = Option<T>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait,