Struct wild_thread_pool::ThreadPool

pub struct ThreadPool { /* fields omitted */ }

Methods

impl ThreadPool

fn new(
    workers: u64,
    stop_timeout: Duration,
    watch_dead_thread: Duration,
    closed: Arc<AtomicBool>
) -> ThreadPool

fn run<N, W, S, E>(self, new_worker: N) -> Workers<W, S, E> where
    N: NewWorker<Worker = W>,
    W: Worker<Shutdown = S, Err = E>,
    S: Shutdown,
    E: ErrorExt,