pu.pi

Class MemoryAwareParIterator<E>

java.lang.Object

pu.pi.ParIteratorAbstract<E>

pu.pi.StaticParIterator<E>

pu.pi.MemoryAwareParIterator<E>

All Implemented Interfaces:

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

public class MemoryAwareParIterator<E>
extends StaticParIterator<E>

Author: xiaoxing Date: 29/06/13

Nested Class Summary

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

ParIterator.Schedule

Field Summary

Fields inherited from class pu.pi.StaticParIterator

chunks, data, localChunkIterator, localChunks, localIterator

Fields inherited from class pu.pi.ParIteratorAbstract

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

Fields inherited from interface pu.pi.ParIterator

DEFAULT_CHUNKSIZE

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected java.util.List<E>	formatData(java.util.Collection<E> collection)

Methods inherited from class pu.pi.StaticParIterator

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

MemoryAwareParIterator

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

Method Detail

formatData

protected java.util.List<E> formatData(java.util.Collection<E> collection)

Overrides:

formatData in class StaticParIterator<E>