Struct bastion_executor::run_queue::Stealer [−][src]
pub struct Stealer<T> { /* fields omitted */ }
Expand description
A stealer handle of a worker queue.
Stealers can be shared among threads.
Task schedulers typically have a single worker queue per worker thread.
Implementations
Returns back the run queue size for the current worker through stealer
Steals a batch of tasks and pushes them into another worker.
How many tasks exactly will be stolen is not specified. That said, this method will try to steal around half of the tasks in the queue, but also not more than some constant limit.
Steals a batch of tasks, pushes them into another worker, and pops a task from that worker.
How many tasks exactly will be stolen is not specified. That said, this method will try to steal around half of the tasks in the queue, but also not more than some constant limit.
Steals a batch of tasks and amend to the given worker’s run queue with the specified amount. If requested amount is above the threshold of time-ahead it defaults to time-ahead amount.
Trait Implementations
Auto Trait Implementations
impl<T> RefUnwindSafe for Stealer<T> where
T: RefUnwindSafe,
impl<T> UnwindSafe for Stealer<T> where
T: RefUnwindSafe,
Blanket Implementations
Mutably borrows from an owned value. Read more
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more