Struct parallel_processor::buckets::concurrent::BucketsThreadDispatcher

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

Implementations

impl<B: LockFreeBucket, S: BucketItemSerializer> BucketsThreadDispatcher<B, S>

pub fn new( mtb: &Arc<MultiThreadBuckets<B>>, thread_data: BucketsThreadBuffer ) -> Self

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

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

pub fn finalize(self) -> (BucketsThreadBuffer, Arc<MultiThreadBuckets<B>>)