Trait brotli::enc::threading::BatchSpawnable

pub trait BatchSpawnable<T: Send + 'static, Alloc: BrotliAlloc + Send + 'static, U: Send + 'static + Sync>where
    <Alloc as Allocator<u8>>::AllocatedMemory: Send + 'static,{
    type JoinHandle: Joinable<T, BrotliEncoderThreadError>;
    type FinalJoinHandle: OwnedRetriever<U>;

    fn batch_spawn<F: Fn(usize, usize, &U, Alloc) -> T + Send + 'static + Copy>(
        &mut self,
        input: &mut Owned<U>,
        alloc_per_thread: &mut [SendAlloc<T, Alloc, Self::JoinHandle>],
        f: F
    ) -> Self::FinalJoinHandle;
}

Required Associated Types

type JoinHandle: Joinable<T, BrotliEncoderThreadError>

type FinalJoinHandle: OwnedRetriever<U>

Required Methods

fn batch_spawn<F: Fn(usize, usize, &U, Alloc) -> T + Send + 'static + Copy>(
    &mut self,
    input: &mut Owned<U>,
    alloc_per_thread: &mut [SendAlloc<T, Alloc, Self::JoinHandle>],
    f: F
) -> Self::FinalJoinHandle

Implementors

impl<T: Send + 'static, Alloc: BrotliAlloc + Send + 'static, U: Send + 'static + Sync> BatchSpawnable<T, Alloc, U> for MultiThreadedSpawnerwhere
    <Alloc as Allocator<u8>>::AllocatedMemory: Send + 'static,

type JoinHandle = MultiThreadedJoinable<T, BrotliEncoderThreadError>

type FinalJoinHandle = Arc<RwLock<U>>

impl<T: Send + 'static, Alloc: BrotliAlloc + Send + 'static, U: Send + 'static + Sync> BatchSpawnable<T, Alloc, U> for SingleThreadedSpawnerwhere
    <Alloc as Allocator<u8>>::AllocatedMemory: Send + 'static,

type JoinHandle = SingleThreadedJoinable<T, BrotliEncoderThreadError>

type FinalJoinHandle = SingleThreadedOwnedRetriever<U>