Struct tikv_util::worker::future::Worker

pub struct Worker<T: Display> {
    scheduler: Scheduler<T>,
    receiver: Mutex<Option<UnboundedReceiver<Option<T>>>>,
    handle: Option<JoinHandle<()>>,
}

A worker that can schedule time consuming tasks.

Fields

scheduler: Scheduler<T>

receiver: Mutex<Option<UnboundedReceiver<Option<T>>>>

handle: Option<JoinHandle<()>>

Implementations

impl<T: Display + Send + 'static> Worker<T>

pub fn new<S: Into<Arc<str>>>(name: S) -> Worker<T>

Creates a worker.

pub fn start<R>(&mut self, runner: R) -> Result<(), Error> where
    R: Runnable<T> + Send + 'static, 

Starts the worker.

pub fn scheduler(&self) -> Scheduler<T>

Gets a scheduler to schedule the task.

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

Schedules a task to run.

If the worker is stopped, an error will return.

pub fn is_busy(&self) -> bool

Checks if underlying worker can’t handle task immediately.

pub fn name(&self) -> &str

pub fn stop(&mut self) -> Option<JoinHandle<()>>

Stops the worker thread.