Struct yatp::task::callback::Runner

[+] Show declaration

pub struct Runner { /* fields omitted */ }

[−] Expand description

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[+]

[+] Show hidden undocumented items

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[+]

[+] Show hidden undocumented items

fn default() -> Self[−]

Returns the “default value” for a type.

impl Runner for Runner[+]

[+] Show hidden undocumented items

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.