pu.pi

Class GuidedParIterator<E>

java.lang.Object

pu.pi.ParIteratorAbstract<E>

pu.pi.DynamicParIterator<E>

pu.pi.GuidedParIterator<E>

All Implemented Interfaces:

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

public class GuidedParIterator<E>
extends DynamicParIterator<E>

Author: xiaoxing Date: 1/06/13

Nested Class Summary

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

ParIterator.Schedule

Field Summary

Fields inherited from class pu.pi.DynamicParIterator

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
GuidedParIterator(java.util.Collection<E> collection, int chunkSize, int numOfThreads, boolean ignoreBarrier)

Method Summary

Modifier and Type	Method and Description
protected java.util.Iterator<java.util.List<E>>	partition(java.util.Collection<E> collection, int minChunkSize, int numOfThreads)

Methods inherited from class pu.pi.DynamicParIterator

forEachRemaining, hasNext, localBreak, next, reset

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

Constructor Detail

GuidedParIterator

public GuidedParIterator(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 minChunkSize,
                                                          int numOfThreads)

Overrides:

partition in class DynamicParIterator<E>