Struct parallel_processor::buckets::single::SingleBucketThreadDispatcher

pub struct SingleBucketThreadDispatcher<'a, B: LockFreeBucket, S: BucketItemSerializer> { /* private fields */ }

Implementations

impl<'a, B: LockFreeBucket, S: BucketItemSerializer> SingleBucketThreadDispatcher<'a, B, S>

pub fn new( buffer_size: MemoryDataSize, bucket_index: u16, buckets: &'a MultiThreadBuckets<B> ) -> Self

pub fn get_bucket_index(&self) -> u16

pub fn get_path(&self) -> PathBuf

pub fn add_element_extended( &mut self, extra_data: &S::ExtraData, extra_buffer: &S::ExtraDataBuffer, element: &S::InputElementType<'_> )

pub fn add_element( &mut self, extra_data: &S::ExtraData, element: &S::InputElementType<'_> )where S: BucketItemSerializer<ExtraDataBuffer = ()>,

pub fn finalize(self)

Trait Implementations

impl<'a, B: LockFreeBucket, S: BucketItemSerializer> Drop for SingleBucketThreadDispatcher<'a, B, S>

fn drop(&mut self)

Executes the destructor for this type.