Struct tikv_util::worker::future::Scheduler

pub struct Scheduler<T> {
    name: Arc<str>,
    sender: UnboundedSender<Option<T>>,
    metrics_pending_task_count: IntGauge,
}

Scheduler provides interface to schedule task to underlying workers.

Fields

name: Arc<str>

sender: UnboundedSender<Option<T>>

metrics_pending_task_count: IntGauge

Implementations

impl<T: Display> Scheduler<T>

pub fn new<S: Into<Arc<str>>>(
    name: S,
    sender: UnboundedSender<Option<T>>
) -> Scheduler<T>

pub fn schedule(&self, task: T) -> Result<(), Stopped<T>>

Schedules a task to run.

If the worker is stopped, an error will return.

Trait Implementations

impl<T: Display> Clone for Scheduler<T>

fn clone(&self) -> Scheduler<T>

Returns a copy of the value.

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

Performs copy-assignment from source.