Struct syncbox::ThreadPool [] [src]

pub struct ThreadPool<T: Task + 'static, Q: WorkQueue<T> = LinkedQueue<Option<T>>> {
    // some fields omitted
}

Methods

impl<T: Task + 'static> ThreadPool<T, LinkedQueue<Option<T>>>

fn fixed_size(size: u32) -> ThreadPool<T, LinkedQueue<Option<T>>>

fn single_thread() -> ThreadPool<T, LinkedQueue<Option<T>>>

impl<T: Task + 'static, Q: WorkQueue<T>> ThreadPool<T, Q>

fn new(core_pool_size: u32, maximum_pool_size: u32, work_queue: Q) -> ThreadPool<T, Q>

fn prestart_core_thread(&self)

fn prestart_all_core_threads(&self)

fn shutdown(&self)

fn shutdown_now(&self)

fn is_shutdown(&self) -> bool

fn await_termination(&self)

Trait Implementations

impl<T: Task + 'static, Q: WorkQueue<T>> Run<T> for ThreadPool<T, Q>

fn run(&self, task: T)

impl<T: Task + 'static, Q: WorkQueue<T>> Clone for ThreadPool<T, Q>

fn clone(&self) -> ThreadPool<T, Q>

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