Struct SimpleBackoffScheduler 

pub struct SimpleBackoffScheduler { /* private fields */ }

Simple backoff scheduler for test/bench use.

• Steps immediately when ready or when there’s no prior result.
• Backs off on backpressure (longer wait).
• Idles on no-input/waiting (shorter wait).
• Stops when the shared AtomicBool is set.

Implementations

impl SimpleBackoffScheduler

pub fn new( stop: Arc<AtomicBool>, idle_micros: u64, backpressure_micros: u64, ) -> Self

Create a new scheduler with the given stop flag and backoff durations.

Trait Implementations

impl WorkerScheduler for SimpleBackoffScheduler

fn decide(&self, state: &WorkerState) -> WorkerDecision

Decide what this worker should do next.