Struct threads_pool::ThreadPool

pub struct ThreadPool { /* fields omitted */ }

Methods

impl ThreadPool

pub fn new(size: usize) -> ThreadPool

pub fn new_with_config(size: usize, config: Config) -> ThreadPool

pub fn set_exec_timeout(&mut self, timeout: Option<Duration>)

pub fn toggle_auto_scale(&mut self, auto_scale: bool)

pub fn exec<F: FnOnce() + Send + 'static>(
    &mut self,
    f: F,
    prioritized: bool
) -> Result<(), ExecutionError>

pub fn execute<F: FnOnce() + Send + 'static>(
    &self,
    f: F
) -> Result<(), ExecutionError>

pub fn execute_with_autoscale<F: FnOnce() + Send + 'static>(
    &mut self,
    f: F
) -> Result<(), ExecutionError>

Deprecated since 0.1.10:

Setup auto-scale using self.toggle_auto_scale(true), then call function self.exec(...) instead; this API will be removed in 0.2.0

Trait Implementations

impl ThreadPoolStates for ThreadPool

fn set_exec_timeout(&mut self, timeout: Option<Duration>)

fn get_exec_timeout(&self) -> Option<Duration>

fn toggle_auto_scale(&mut self, auto_scale: bool)

fn auto_scale_enabled(&self) -> bool

impl PoolManager for ThreadPool

fn extend(&mut self, more: usize)

fn shrink(&mut self, less: usize)

fn resize(&mut self, total: usize)

fn auto_adjust(&mut self)

fn auto_expire(&mut self, life: Option<Duration>)

fn kill_worker(&mut self, id: usize)

fn clear(&mut self)

fn close(&mut self)

fn force_close(&mut self)

impl PoolState for ThreadPool

fn get_size(&self) -> usize

fn get_queue_length(&self) -> usize

fn get_priority_queue_length(&self) -> usize

fn get_queue_size_threshold(&self) -> usize

fn set_queue_size_threshold(&mut self, threshold: usize)

fn get_first_worker_id(&self) -> Option<usize>

fn get_last_worker_id(&self) -> Option<usize>

fn get_next_worker_id(&self, current_id: usize) -> Option<usize>

impl Drop for ThreadPool

fn drop(&mut self)

Executes the destructor for this type.