Struct tikv_util::worker::pool::Worker

pub struct Worker {
    pool: Arc<Mutex<Option<ThreadPool<TaskCell>>>>,
    remote: Remote<TaskCell>,
    pending_capacity: usize,
    counter: Arc<AtomicUsize>,
    stop: Arc<AtomicBool>,
    thread_count: usize,
}

A worker that can schedule time consuming tasks.

Fields

pool: Arc<Mutex<Option<ThreadPool<TaskCell>>>>

remote: Remote<TaskCell>

pending_capacity: usize

counter: Arc<AtomicUsize>

stop: Arc<AtomicBool>

thread_count: usize

Implementations

impl Worker

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

pub fn start<R: Runnable + 'static, S: Into<String>>(
    &self,
    name: S,
    runner: R
) -> Scheduler<R::Task>

pub fn start_with_timer<R: RunnableWithTimer + 'static, S: Into<String>>(
    &self,
    name: S,
    runner: R
) -> Scheduler<R::Task>

pub fn spawn_interval_task<F>(&self, interval: Duration, func: F) where
    F: FnMut() + Send + 'static, 

fn delay_notify<T: Display + Send + 'static>(
    tx: UnboundedSender<Msg<T>>,
    timeout: Duration
)

pub fn lazy_build<T: Display + Send + 'static, S: Into<String>>(
    &self,
    name: S
) -> LazyWorker<T>

pub fn stop(&self)

Stops the worker thread.

pub fn is_busy(&self) -> bool

Checks if underlying worker can’t handle task immediately.

fn start_impl<R: Runnable + 'static>(
    &self,
    runner: R,
    receiver: UnboundedReceiver<Msg<R::Task>>,
    metrics_pending_task_count: IntGauge
)

fn start_with_timer_impl<R>(
    &self,
    runner: R,
    tx: UnboundedSender<Msg<R::Task>>,
    receiver: UnboundedReceiver<Msg<R::Task>>,
    metrics_pending_task_count: IntGauge
) where
    R: RunnableWithTimer + 'static, 

Trait Implementations

impl Clone for Worker

fn clone(&self) -> Worker

Returns a copy of the value.

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

Performs copy-assignment from source.