Struct brotli::enc::worker_pool::WorkerPool

pub struct WorkerPool<ReturnValue: Send + 'static, ExtraInput: Send + 'static, Alloc: BrotliAlloc + Send + 'static, U: Send + 'static + Sync> { /* fields omitted */ }

Methods

impl<ReturnValue: Send + 'static, ExtraInput: Send + 'static, Alloc: BrotliAlloc + Send + 'static, U: Send + 'static + Sync> WorkerPool<ReturnValue, ExtraInput, Alloc, U>

pub fn new(num_threads: usize) -> Self

Trait Implementations

impl<ReturnValue: Send + 'static, ExtraInput: Send + 'static, Alloc: BrotliAlloc + Send + 'static, U: Send + 'static + Sync> BatchSpawnableLite<ReturnValue, ExtraInput, Alloc, U> for WorkerPool<ReturnValue, ExtraInput, Alloc, U> where
    <Alloc as Allocator<u8>>::AllocatedMemory: Send + 'static,
    <Alloc as Allocator<u16>>::AllocatedMemory: Send + Sync,
    <Alloc as Allocator<u32>>::AllocatedMemory: Send + Sync, 

type FinalJoinHandle = Arc<RwLock<U>>

type JoinHandle = WorkerJoinable<ReturnValue, ExtraInput, Alloc, U>

fn make_spawner(&mut self, input: &mut Owned<U>) -> Self::FinalJoinHandle

fn spawn(
    &mut self,
    locked_input: &mut Self::FinalJoinHandle,
    work: &mut SendAlloc<ReturnValue, ExtraInput, Alloc, Self::JoinHandle>,
    index: usize,
    num_threads: usize,
    f: fn(_: ExtraInput, _: usize, _: usize, _: &U, _: Alloc) -> ReturnValue
)

impl<ReturnValue: Send + 'static, ExtraInput: Send + 'static, Alloc: BrotliAlloc + Send + 'static, U: Send + 'static + Sync> Drop for WorkerPool<ReturnValue, ExtraInput, Alloc, U>

fn drop(&mut self)

Executes the destructor for this type.