Package gov.nih.mipav.model.algorithms

Class ContourPlot.ParallelForEachExecutor<T>

java.lang.Object

java.util.concurrent.ForkJoinTask<Void>

java.util.concurrent.CountedCompleter<Void>

gov.nih.mipav.model.algorithms.ContourPlot.ParallelForEachExecutor<T>

All Implemented Interfaces:

Serializable, Future<Void>

Enclosing class:

ContourPlot

public final class ContourPlot.ParallelForEachExecutor<T>
extends CountedCompleter<Void>

CountedCompleter class for multithreaded execution of a Consumer on a Spliterator. Used to realise multithreaded forEach loop in ContourPlot.ImgBase.forEach(Consumer).

Since:

2.0 (relocated from Img class)

Author:

hageldave

See Also:

• ContourPlot.ImgBase.forEach(boolean parallel, Consumer action)
• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface java.util.concurrent.Future

Future.State

Field Summary

Fields

Modifier and Type	Field	Description
private final Consumer<? super T>	action
private static final long	serialVersionUID
private final Spliterator<T>	spliterator

Constructor Summary

Constructors

Modifier	Constructor	Description
private	ParallelForEachExecutor(ContourPlot.ParallelForEachExecutor<T> parent, Spliterator<T> spliterator, Consumer<? super T> action)
	ParallelForEachExecutor(Spliterator<T> spliterator, Consumer<? super T> action)	Creates a new ParallelForEachExecutor that executes the specified Consumer (action) on the elements of the specified Spliterator.

Method Summary

Modifier and Type	Method	Description
void	compute()

Methods inherited from class java.util.concurrent.CountedCompleter

addToPendingCount, compareAndSetPendingCount, complete, decrementPendingCountUnlessZero, exec, firstComplete, getCompleter, getPendingCount, getRawResult, getRoot, helpComplete, nextComplete, onCompletion, onExceptionalCompletion, propagateCompletion, quietlyCompleteRoot, setPendingCount, setRawResult, tryComplete

Methods inherited from class java.util.concurrent.ForkJoinTask

adapt, adapt, adapt, adaptInterruptible, cancel, compareAndSetForkJoinTaskTag, completeExceptionally, exceptionNow, 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, quietlyJoin, quietlyJoinUninterruptibly, reinitialize, resultNow, setForkJoinTaskTag, state, tryUnfork

Methods inherited from class java.lang.Object

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

Field Details

serialVersionUID

private static final long serialVersionUID

See Also:

• Constant Field Values

spliterator

private final Spliterator<T> spliterator

action

private final Consumer<? super T> action

Constructor Details

ParallelForEachExecutor

public ParallelForEachExecutor(Spliterator<T> spliterator,
 Consumer<? super T> action)

Creates a new ParallelForEachExecutor that executes the specified Consumer (action) on the elements of the specified Spliterator. In parallel.

Call ForkJoinTask.invoke() to trigger execution.

Parameters:

spliterator - that provides the elements on which the action is to be performed

action - to be performed

ParallelForEachExecutor

private ParallelForEachExecutor(ContourPlot.ParallelForEachExecutor<T> parent,
 Spliterator<T> spliterator,
 Consumer<? super T> action)

Method Details

compute

public void compute()

Specified by:

compute in class CountedCompleter<Void>