pu.pi

Class DynamicParIterator<E>

java.lang.Object

pu.pi.ParIteratorAbstract<E>

pu.pi.DynamicParIterator<E>

All Implemented Interfaces:

java.util.Iterator<E>, ParIterator<E>

Direct Known Subclasses:

GuidedParIterator

public class DynamicParIterator<E>
extends ParIteratorAbstract<E>

Author: xiaoxing Date: 1/06/13

Nested Class Summary

Nested classes/interfaces inherited from interface pu.pi.ParIterator

ParIterator.Schedule

Field Summary

Fields

Modifier and Type	Field and Description
protected TLocal<java.util.Iterator<E>>	localIterator

Fields inherited from class pu.pi.ParIteratorAbstract

chunkSize, collection, data, exceptions, flags, ignoreBarrier, latch, numOfThreads, reclaimedElements, threadID

Fields inherited from interface pu.pi.ParIterator

DEFAULT_CHUNKSIZE

Constructor Summary

Constructors

Constructor and Description
DynamicParIterator(java.util.Collection<E> collection, int chunkSize, int numOfThreads, boolean ignoreBarrier)

Method Summary

Modifier and Type	Method and Description
void	forEachRemaining(java.util.function.Consumer<? super E> action)
boolean	hasNext() Checks to see if any elements remain for the current thread.
boolean	localBreak() Attempts to excuse the current thread from continuing to iterate (and re-distribute all unprocessed elements to the other threads).
E	next() Returns an element for the current thread to process.
protected java.util.Iterator<java.util.List<E>>	partition(java.util.Collection<E> collection, int chunkSize, int numOfThreads)
void	reset() Reset ParIterator for reuse.

Methods inherited from class pu.pi.ParIteratorAbstract

allOtherThreadsHaveLocalBreaked, getAllExceptions, getID, globalBreak, register, register, remove

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

localIterator

protected final TLocal<java.util.Iterator<E>> localIterator

Constructor Detail

DynamicParIterator

public DynamicParIterator(java.util.Collection<E> collection,
                          int chunkSize,
                          int numOfThreads,
                          boolean ignoreBarrier)

Method Detail

partition

protected java.util.Iterator<java.util.List<E>> partition(java.util.Collection<E> collection,
                                                          int chunkSize,
                                                          int numOfThreads)

hasNext

public boolean hasNext()

Description copied from interface: ParIterator

Checks to see if any elements remain for the current thread. If such an element exists, true is returned and the current thread must follow up with a binding call to next(). A thread must continue to obtain elements in this fashion until this method returns false.

Note that this method involves an implicit barrier for the last call to hasNext() in order to ensure all threads finish at the same time.

Returns:

true if at least one element has been reserved for the calling thread (in which case it must follow up with a call to next()).
false otherwise (in such a case, the calling thread blocks until all the other threads have completed their iterations).

See Also:

ParIterator.next()

next

public E next()

Description copied from interface: ParIterator

Returns an element for the current thread to process. A thread must not call this method unless it has previously called hasNext() (and received true).

Note that calls to hasNext() (that return true) only allow for one corresponding and binding call to hasNext(). Therefore, multiple calls to hasNext() have no effect until the corresponding call to next() takes place.

See Also:

ParIterator.hasNext()

localBreak

public boolean localBreak()

Description copied from interface: ParIterator

Attempts to excuse the current thread from continuing to iterate (and re-distribute all unprocessed elements to the other threads). This is only successful if the the elements previously assigned to this thread are successfully allocated to the other thread(s). If the elements cannot be assigned to another thread (because the other threads have already stopped processing), then this attempt to local break will fail.

Therefore, (as opposed to globalBreak()) this method guarantees that even if all threads attempt to localBreak(), at least one will fail and is left to traverse the remaining elements. Note that in many cases, calling localBreak() will break the original scheduling policy.

Returns:

true if the attempt is successful, false otherwise.

See Also:

ParIterator.globalBreak()

reset

public void reset()

Description copied from interface: ParIterator

Reset ParIterator for reuse.

Specified by:

reset in interface ParIterator<E>

Overrides:

reset in class ParIteratorAbstract<E>

forEachRemaining

public void forEachRemaining(java.util.function.Consumer<? super E> action)