Package org.processmining.specpp.evaluation.fitness.parallelized

Class AbstractEnumSetReplayTask<E extends java.lang.Enum<E>,R>

java.lang.Object

java.util.concurrent.ForkJoinTask<V>

java.util.concurrent.RecursiveTask<R>

org.processmining.specpp.evaluation.fitness.parallelized.AbstractEnumSetReplayTask<E,R>

All Implemented Interfaces:

java.io.Serializable, java.util.concurrent.Future<R>

Direct Known Subclasses:

BasicReplayTask, ComprehensiveReplayTask, DetailedReplayTask

public abstract class AbstractEnumSetReplayTask<E extends java.lang.Enum<E>,R>
extends java.util.concurrent.RecursiveTask<R>

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
protected static long	MIN_SPLITTING_SIZE
protected java.util.Spliterator<IndexedItem<java.util.EnumSet<E>>>	toAggregate
protected java.util.function.IntUnaryOperator	variantCountMapper

Constructor Summary

Constructors

Constructor	Description
AbstractEnumSetReplayTask(java.util.Spliterator<IndexedItem<java.util.EnumSet<E>>> toAggregate, java.util.function.IntUnaryOperator variantCountMapper)

Method Summary

Modifier and Type	Method	Description
protected abstract R	combineIntoFirst(R first, R second)
protected R	compute()
protected abstract R	computeHere()
protected abstract AbstractEnumSetReplayTask<E,R>	createSubTask(java.util.Spliterator<IndexedItem<java.util.EnumSet<E>>> spliterator)

Methods inherited from class java.util.concurrent.RecursiveTask

exec, getRawResult, setRawResult

Methods inherited from class java.util.concurrent.ForkJoinTask

adapt, adapt, adapt, cancel, compareAndSetForkJoinTaskTag, complete, completeExceptionally, fork, get, get, getException, getForkJoinTaskTag, getPool, getQueuedTaskCount, getSurplusQueuedTaskCount, helpQuiesce, inForkJoinPool, invoke, invokeAll, invokeAll, invokeAll, isCancelled, isCompletedAbnormally, isCompletedNormally, isDone, join, peekNextLocalTask, pollNextLocalTask, pollSubmission, pollTask, quietlyComplete, quietlyInvoke, quietlyJoin, reinitialize, setForkJoinTaskTag, tryUnfork

Methods inherited from class java.lang.Object

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

Field Detail

MIN_SPLITTING_SIZE

protected static final long MIN_SPLITTING_SIZE

See Also:

Constant Field Values

toAggregate

protected final java.util.Spliterator<IndexedItem<java.util.EnumSet<E extends java.lang.Enum<E>>>> toAggregate

variantCountMapper

protected final java.util.function.IntUnaryOperator variantCountMapper

Constructor Detail

AbstractEnumSetReplayTask

public AbstractEnumSetReplayTask(java.util.Spliterator<IndexedItem<java.util.EnumSet<E>>> toAggregate,
                                 java.util.function.IntUnaryOperator variantCountMapper)

Method Detail

computeHere

protected abstract R computeHere()

combineIntoFirst

protected abstract R combineIntoFirst(R first,
                                      R second)

createSubTask

protected abstract AbstractEnumSetReplayTask<E,R> createSubTask(java.util.Spliterator<IndexedItem<java.util.EnumSet<E>>> spliterator)

compute

protected R compute()

Specified by:

compute in class java.util.concurrent.RecursiveTask<R>