Struct tikv_util::yatp_pool::YatpPoolBuilder

[+] Show declaration

pub struct YatpPoolBuilder<T: PoolTicker> {
    name_prefix: Option<String>,
    ticker: TickerWrapper<T>,
    after_start: Option<Arc<dyn Fn() + Send + Sync>>,
    before_stop: Option<Arc<dyn Fn() + Send + Sync>>,
    before_pause: Option<Arc<dyn Fn() + Send + Sync>>,
    min_thread_count: usize,
    max_thread_count: usize,
    stack_size: usize,
    max_tasks: usize,
}

Fields

name_prefix: Option<String>

ticker: TickerWrapper<T>

after_start: Option<Arc<dyn Fn() + Send + Sync>>

before_stop: Option<Arc<dyn Fn() + Send + Sync>>

before_pause: Option<Arc<dyn Fn() + Send + Sync>>

min_thread_count: usize

max_thread_count: usize

stack_size: usize

max_tasks: usize

Implementations

impl<T: PoolTicker> YatpPoolBuilder<T>[−]

pub fn new(ticker: T) -> Self

pub fn config(&mut self, config: Config) -> &mut Self

pub fn stack_size(&mut self, val: usize) -> &mut Self

pub fn name_prefix(&mut self, val: impl Into<String>) -> &mut Self

pub fn thread_count(
    &mut self,
    min_thread_count: usize,
    max_thread_count: usize
) -> &mut Self

pub fn max_tasks(&mut self, tasks: usize) -> &mut Self

pub fn before_stop<F>(&mut self, f: F) -> &mut Self where
    F: Fn() + Send + Sync + 'static, 

pub fn after_start<F>(&mut self, f: F) -> &mut Self where
    F: Fn() + Send + Sync + 'static, 

pub fn before_pause<F>(&mut self, f: F) -> &mut Self where
    F: Fn() + Send + Sync + 'static, 

pub fn build_future_pool(&mut self) -> FuturePool

pub fn build_single_level_pool(&mut self) -> ThreadPool<TaskCell>

pub fn build_multi_level_pool(&mut self) -> ThreadPool<TaskCell>

fn create_builder(&mut self) -> (Builder, YatpPoolRunner<T>)