Struct tikv_util::worker::pool::LazyWorker

pub struct LazyWorker<T: Display + Send + 'static> {
    scheduler: Scheduler<T>,
    worker: Worker,
    receiver: Option<UnboundedReceiver<Msg<T>>>,
    metrics_pending_task_count: IntGauge,
}

Fields

scheduler: Scheduler<T>

worker: Worker

receiver: Option<UnboundedReceiver<Msg<T>>>

metrics_pending_task_count: IntGauge

Implementations

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

pub fn new<S: Into<String>>(name: S) -> LazyWorker<T>

pub fn start<R: 'static + Runnable<Task = T>>(&mut self, runner: R) -> bool

pub fn start_with_timer<R: 'static + RunnableWithTimer<Task = T>>(
    &mut self,
    runner: R
) -> bool

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

pub fn stop(&mut self)

pub fn stop_worker(self)