Struct mutringbuf::iterators::sync_iterators::detached_work_iter::DetachedWorkIter

pub struct DetachedWorkIter<B: MutRB> { /* private fields */ }

Same as WorkIter, but does not update the atomic index when advancing.

This makes it possible to explore available data back and forth, putting the consumer iterator on hold.

A typical use case of this structure is to search something amidst produced dataligning the detached iterator to a suitable indexnd then returning to a normal worker iterator.

This struct can only be created by detaching a worker iterator.

When done worker iterator can be re-obtained via Self::attach.

Note that, in order to avoid buffer saturationtomic index can be synced with Self::sync_index; this synchronises indices making the consumer iterator able to move on.

As WorkIter, this iterator returns mutable references to data stored within the buffer. Thuss stated in the docs written for the former, Self::advance has to be called when done with the mutation in order to move the iterator.

Implementations

impl<B: MutRB<Item = T>, T> DetachedWorkIter<B>

pub fn attach(self) -> WorkIter<B>

Attaches the iterator, yielding a WorkIter.

pub fn available(&mut self) -> usize

Same as WorkIter::available.

pub fn index(&self) -> usize

Same as WorkIter::index.

pub fn buf_len(&self) -> usize

Same as WorkIter::buf_len.

pub unsafe fn set_index(&mut self, index: usize)

Sets local index.

Safety

Index must always be between consumer and producer.

pub fn reset_index(&mut self)

Resets the local index of the iterator. I.e., moves the iterator to the location occupied by its successor. To sync with the atomic index, use Self::sync_index.

pub unsafe fn advance(&mut self, count: usize)

Advances the iterator as in WorkIter::available(), but does not modify the atomic counter, making the change local.

Safety

See WorkIter::advance.

pub unsafe fn go_back(&mut self, count: usize)

Goes back, wrapping if necessary.

Safety

Index must always be between consumer and producer.

pub fn is_prod_alive(&self) -> bool

Same as WorkIter::is_prod_alive.

pub fn is_cons_alive(&self) -> bool

Same as WorkIter::is_cons_alive.

pub fn get_workable(&mut self) -> Option<&mut T>

Same as WorkIter::get_workable.

pub fn get_workable_slice_exact( &mut self, count: usize ) -> Option<WorkableSlice<'_, T>>

Same as WorkIter::get_workable_slice_exact.

pub fn get_workable_slice_avail(&mut self) -> Option<WorkableSlice<'_, T>>

Same as WorkIter::get_workable_slice_avail.

pub fn get_workable_slice_multiple_of( &mut self, rhs: usize ) -> Option<WorkableSlice<'_, T>>

Same as WorkIter::get_workable_slice_multiple_of.

pub fn sync_index(&self)

Synchronises the underlying atomic index with the local index. I.e. let the consumer iterator advance.

Trait Implementations

impl<B: ConcurrentRB + MutRB<Item = T>, T> Send for DetachedWorkIter<B>