Struct yatp::task::callback::Runner

pub struct Runner { /* fields omitted */ }

Callback task runner.

It’s possible that a task can’t be finished in a single execution and needs to be rerun. max_inspace_spin is the maximum times a task is rerun at once before being put back to the thread pool.

Implementations

impl Runner

pub fn new(max_inplace_spin: usize) -> Self

Creates a new runner with given max_inplace_spin.

pub fn set_max_inplace_spin(&mut self, max_inplace_spin: usize)

Sets max_inplace_spin.

Trait Implementations

impl Clone for Runner

fn clone(&self) -> Runner

Returns a copy of the value.

pub fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for Runner

fn default() -> Self

Returns the “default value” for a type.

impl Runner for Runner

type TaskCell = TaskCell

The local spawn that can be accepted to spawn tasks.

fn handle(&mut self, local: &mut Local<TaskCell>, task_cell: TaskCell) -> bool

Called when a task needs to be handled.

fn start(&mut self, _local: &mut Local<Self::TaskCell>)

Called when the runner is started.

fn pause(&mut self, _local: &mut Local<Self::TaskCell>) -> bool

Called when the runner is put to sleep.

fn resume(&mut self, _local: &mut Local<Self::TaskCell>)

Called when the runner is woken up.

fn end(&mut self, _local: &mut Local<Self::TaskCell>)

Called when the runner is about to be destroyed.