Struct ParallelIterator 

pub struct ParallelIterator<DiscQ, T>
where
    DiscQ: DiscreteQueue<Output = T>,
{
    pub iter: DiscQ,
    /* private fields */
}

ParallelIterator is comparable to Iter, but is set up for the AtomicIterator.

Fields

iter: DiscQ

Implementations

impl<DiscQ, T> ParallelIterator<DiscQ, T>

where DiscQ: DiscreteQueue<Output = T>,

pub fn new(iter: DiscQ) -> Self

Trait Implementations

impl<DiscQ, T> AtomicIterator for ParallelIterator<DiscQ, T>

where DiscQ: DiscreteQueue<Output = T>,

type AtomicItem = <DiscQ as DiscreteQueue>::Output

fn atomic_next(&mut self) -> Option<Self::AtomicItem>

fn len(&self) -> Option<usize>

fn is_active(&self) -> bool

tests whether the iterator is still active with values still available to be pulled

fn atomic_pull(&mut self) -> Option<Vec<Self::AtomicItem>>