Struct yatp::pool::ThreadPool[−][src]

pub struct ThreadPool<T: TaskCell + Send> { /* fields omitted */ }
[−]

A generic thread pool.

Implementations

impl<T: TaskCell + Send> ThreadPool<T>[src][−]

pub fn spawn(&self, t: impl WithExtras<T>)[src][−]

Spawns the task into the thread pool.

If the pool is shutdown, it becomes no-op.

pub fn shutdown(&self)[src][−]

Shutdowns the pool.

Closes the queue and wait for all threads to exit.

pub fn remote(&self) -> &Remote<T>[src][−]

Get a remote queue for spawning tasks without owning the thread pool.

Trait Implementations

impl<T: TaskCell + Send> Drop for ThreadPool<T>[src][+]

fn drop(&mut self)[src][−]

Will shutdown the thread pool if it has not.

Auto Trait Implementations

impl<T> !RefUnwindSafe for ThreadPool<T>

impl<T> Send for ThreadPool<T>

impl<T> Sync for ThreadPool<T>

impl<T> Unpin for ThreadPool<T>

impl<T> !UnwindSafe for ThreadPool<T>

Blanket Implementations

impl<T> Any for T where
    T: 'static + ?Sized, [src][+]

impl<T> Borrow<T> for T where
    T: ?Sized, [src][+]

impl<T> BorrowMut<T> for T where
    T: ?Sized, [src][+]

impl<T> From<T> for T[src][+]

impl<T> Instrument for T[src][+]

impl<T, U> Into<U> for T where
    U: From<T>, [src][+]

impl<T, U> TryFrom<U> for T where
    U: Into<T>, [src][+]

type Error = Infallible

The type returned in the event of a conversion error.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, [src][+]

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

impl<V, T> VZip<V> for T where
    V: MultiLane<T>, [src][+]