Struct backup::endpoint::ControlThreadPool

struct ControlThreadPool {
    size: usize,
    workers: Option<Arc<ThreadPool<TaskCell>>>,
    last_active: Instant,
}

Fields

size: usize

workers: Option<Arc<ThreadPool<TaskCell>>>

last_active: Instant

Implementations

impl ControlThreadPool

fn new() -> Self

fn spawn<F>(&mut self, func: F) where
    F: FnOnce() + Send + 'static, 

fn adjust_with(&mut self, new_size: usize)

Lazily adjust the thread pool’s size

Resizing if the thread pool need to expend or there are too many idle threads. Otherwise do nothing.

fn heartbeat(&mut self)

fn check_active(&mut self, idle_threshold: Duration)

Shutdown the thread pool if it has been idle for a long time.