Package fj.impl

Class AbstractForkJoin

java.lang.Object

fj.impl.AbstractForkJoin

All Implemented Interfaces:

ForkJoin

Direct Known Subclasses:

ExecutorForkJoin, ImpartialForkJoin, LinearForkJoin

public abstract class AbstractForkJoin
extends Object
implements ForkJoin

Author:

Dennis Cosgrove

Constructor Summary

Constructors

Constructor	Description
AbstractForkJoin()

Method Summary

Modifier and Type	Method	Description
<R> Future<R>[]	fork_loop(int min, int maxExclusive, TaskIntFunction<R> intFunction)
<T, R> List<Future<R>>	fork_loop(Iterable<T> iterable, TaskFunction<T,R> function)
<T, R> Future<R>[]	fork_loop(T[] array, TaskFunction<T,R> function)
<T, R> List<Future<R>>	fork_loop_with_index(Iterable<T> iterable, TaskFunctionWithIndex<T,R> functionWithIndex)
<T, R> Future<R>[]	fork_loop_with_index(T[] array, TaskFunctionWithIndex<T,R> functionWithIndex)
protected abstract <T> List<Future<T>>	invokeAllAndGetAll(Collection<? extends Callable<T>> tasks)
<R> List<R>	join(Collection<Future<R>> futures)
<R> R	join(Future<R> future)
<R> List<R>	join(Future<R>[] futures)
<R> List<R>	join(Future<R> a, Future<R> b, Future<R>... cToZ)
<R> R[]	join(IntFunction<R[]> returnValueArrayCreator, Future<R>[] futures)
<R> R[]	join(IntFunction<R[]> returnValueArrayCreator, Future<R> a, Future<R> b, Future<R>... cToZ)
<R> List<R>	join_fork_loop(int min, int maxExclusive, TaskIntFunction<R> intFunction)
<T, R> List<R>	join_fork_loop(Iterable<T> iterable, TaskFunction<T,R> function)
<R> R[]	join_fork_loop(IntFunction<R[]> returnValueArrayCreator, int min, int maxExclusive, TaskIntFunction<R> function)
<T, R> R[]	join_fork_loop(IntFunction<R[]> returnValueArrayCreator, T[] array, TaskFunction<T,R> function)
<T, R> List<R>	join_fork_loop(T[] array, TaskFunction<T,R> function)
<T, R> List<R>	join_fork_loop_with_index(Iterable<T> iterable, TaskFunctionWithIndex<T,R> functionWithIndex)
<T, R> R[]	join_fork_loop_with_index(IntFunction<R[]> returnValueArrayCreator, T[] array, TaskFunctionWithIndex<T,R> functionWithIndex)
<T, R> List<R>	join_fork_loop_with_index(T[] array, TaskFunctionWithIndex<T,R> functionWithIndex)
void	join_void_fork_loop(int min, int maxExclusive, TaskIntConsumer consumer)
<T> void	join_void_fork_loop(Iterable<T> iterable, TaskConsumer<T> consumer)
<T> void	join_void_fork_loop(T[] array, TaskConsumer<T> consumer)
void	join_void_fork_loop_2d(int aMin, int aMaxExclusive, int bMin, int bMaxExclusive, TaskBiIntConsumer biConsumer)
void	join_void_fork_loop_2d_auto_coarsen(int aMin, int aMaxExclusive, int bMin, int bMaxExclusive, TaskBiIntConsumer biConsumer)
void	join_void_fork_loop_auto_coarsen(int min, int maxExclusive, TaskIntConsumer consumer)
<T> void	join_void_fork_loop_with_index(Iterable<T> iterable, TaskConsumerWithIndex<T> consumerWithIndex)
<T> void	join_void_fork_loop_with_index(T[] array, TaskConsumerWithIndex<T> consumerWithIndex)
Future<Void>	void_fork(TaskRunnable runnable)
Future<Void>[]	void_fork_loop(int min, int maxExclusive, TaskIntConsumer intConsumer)
<T> List<Future<Void>>	void_fork_loop(Iterable<T> iterable, TaskConsumer<T> consumer)
<T> Future<Void>[]	void_fork_loop(T[] array, TaskConsumer<T> consumer)
<T> List<Future<Void>>	void_fork_loop_with_index(Iterable<T> iterable, TaskConsumerWithIndex<T> consumerWithIndex)
<T> Future<Void>[]	void_fork_loop_with_index(T[] array, TaskConsumerWithIndex<T> consumerWithIndex)

Methods inherited from class java.lang.Object

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

Methods inherited from interface fj.api.ForkJoin

fork

Constructor Details

AbstractForkJoin

public AbstractForkJoin()

Method Details

invokeAllAndGetAll

protected abstract <T> List<Future<T>> invokeAllAndGetAll(Collection<? extends Callable<T>> tasks)
                                                   throws InterruptedException,
ExecutionException

Throws:

InterruptedException

ExecutionException

void_fork

public Future<Void> void_fork(TaskRunnable runnable)

Specified by:

void_fork in interface ForkJoin

join

public <R> R join(Future<R> future)
           throws InterruptedException,
ExecutionException

Specified by:

join in interface ForkJoin

Throws:

InterruptedException

ExecutionException

join

public <R> List<R> join(Collection<Future<R>> futures)
                 throws InterruptedException,
ExecutionException

Specified by:

join in interface ForkJoin

Throws:

InterruptedException

ExecutionException

join

public <R> List<R> join(Future<R>[] futures)
                 throws InterruptedException,
ExecutionException

Specified by:

join in interface ForkJoin

Throws:

InterruptedException

ExecutionException

join

public <R> R[] join(IntFunction<R[]> returnValueArrayCreator,
 Future<R>[] futures)
             throws InterruptedException,
ExecutionException

Specified by:

join in interface ForkJoin

Throws:

InterruptedException

ExecutionException

join

public <R> List<R> join(Future<R> a,
 Future<R> b,
 Future<R>... cToZ)
                 throws InterruptedException,
ExecutionException

Specified by:

join in interface ForkJoin

Throws:

InterruptedException

ExecutionException

join

public <R> R[] join(IntFunction<R[]> returnValueArrayCreator,
 Future<R> a,
 Future<R> b,
 Future<R>... cToZ)
             throws InterruptedException,
ExecutionException

Specified by:

join in interface ForkJoin

Throws:

InterruptedException

ExecutionException

fork_loop

public <R> Future<R>[] fork_loop(int min,
 int maxExclusive,
 TaskIntFunction<R> intFunction)

Specified by:

fork_loop in interface ForkJoin

fork_loop

public <T,
R> Future<R>[] fork_loop(T[] array,
 TaskFunction<T,R> function)

Specified by:

fork_loop in interface ForkJoin

fork_loop

public <T,
R> List<Future<R>> fork_loop(Iterable<T> iterable,
 TaskFunction<T,R> function)

Specified by:

fork_loop in interface ForkJoin

fork_loop_with_index

public <T,
R> List<Future<R>> fork_loop_with_index(Iterable<T> iterable,
 TaskFunctionWithIndex<T,R> functionWithIndex)

Specified by:

fork_loop_with_index in interface ForkJoin

fork_loop_with_index

public <T,
R> Future<R>[] fork_loop_with_index(T[] array,
 TaskFunctionWithIndex<T,R> functionWithIndex)

Specified by:

fork_loop_with_index in interface ForkJoin

void_fork_loop

public Future<Void>[] void_fork_loop(int min,
 int maxExclusive,
 TaskIntConsumer intConsumer)

Specified by:

void_fork_loop in interface ForkJoin

void_fork_loop

public <T> Future<Void>[] void_fork_loop(T[] array,
 TaskConsumer<T> consumer)

Specified by:

void_fork_loop in interface ForkJoin

void_fork_loop

public <T> List<Future<Void>> void_fork_loop(Iterable<T> iterable,
 TaskConsumer<T> consumer)

Specified by:

void_fork_loop in interface ForkJoin

void_fork_loop_with_index

public <T> List<Future<Void>> void_fork_loop_with_index(Iterable<T> iterable,
 TaskConsumerWithIndex<T> consumerWithIndex)

Specified by:

void_fork_loop_with_index in interface ForkJoin

void_fork_loop_with_index

public <T> Future<Void>[] void_fork_loop_with_index(T[] array,
 TaskConsumerWithIndex<T> consumerWithIndex)

Specified by:

void_fork_loop_with_index in interface ForkJoin

join_fork_loop

public <R> List<R> join_fork_loop(int min,
 int maxExclusive,
 TaskIntFunction<R> intFunction)
                           throws InterruptedException,
ExecutionException

Specified by:

join_fork_loop in interface ForkJoin

Throws:

InterruptedException

ExecutionException

join_fork_loop

public <R> R[] join_fork_loop(IntFunction<R[]> returnValueArrayCreator,
 int min,
 int maxExclusive,
 TaskIntFunction<R> function)
                       throws InterruptedException,
ExecutionException

Specified by:

join_fork_loop in interface ForkJoin

Throws:

InterruptedException

ExecutionException

join_fork_loop

public <T,
R> List<R> join_fork_loop(T[] array,
 TaskFunction<T,R> function)
                             throws InterruptedException,
ExecutionException

Specified by:

join_fork_loop in interface ForkJoin

Throws:

InterruptedException

ExecutionException

join_fork_loop

public <T,
R> R[] join_fork_loop(IntFunction<R[]> returnValueArrayCreator,
 T[] array,
 TaskFunction<T,R> function)
                         throws InterruptedException,
ExecutionException

Specified by:

join_fork_loop in interface ForkJoin

Throws:

InterruptedException

ExecutionException

join_fork_loop

public <T,
R> List<R> join_fork_loop(Iterable<T> iterable,
 TaskFunction<T,R> function)
                             throws InterruptedException,
ExecutionException

Specified by:

join_fork_loop in interface ForkJoin

Throws:

InterruptedException

ExecutionException

join_fork_loop_with_index

public <T,
R> R[] join_fork_loop_with_index(IntFunction<R[]> returnValueArrayCreator,
 T[] array,
 TaskFunctionWithIndex<T,R> functionWithIndex)
                                    throws InterruptedException,
ExecutionException

Specified by:

join_fork_loop_with_index in interface ForkJoin

Throws:

InterruptedException

ExecutionException

join_fork_loop_with_index

public <T,
R> List<R> join_fork_loop_with_index(T[] array,
 TaskFunctionWithIndex<T,R> functionWithIndex)
                                        throws InterruptedException,
ExecutionException

Specified by:

join_fork_loop_with_index in interface ForkJoin

Throws:

InterruptedException

ExecutionException

join_fork_loop_with_index

public <T,
R> List<R> join_fork_loop_with_index(Iterable<T> iterable,
 TaskFunctionWithIndex<T,R> functionWithIndex)
                                        throws InterruptedException,
ExecutionException

Specified by:

join_fork_loop_with_index in interface ForkJoin

Throws:

InterruptedException

ExecutionException

join_void_fork_loop

public void join_void_fork_loop(int min,
 int maxExclusive,
 TaskIntConsumer consumer)
                         throws InterruptedException,
ExecutionException

Specified by:

join_void_fork_loop in interface ForkJoin

Throws:

InterruptedException

ExecutionException

join_void_fork_loop

public <T> void join_void_fork_loop(T[] array,
 TaskConsumer<T> consumer)
                             throws InterruptedException,
ExecutionException

Specified by:

join_void_fork_loop in interface ForkJoin

Throws:

InterruptedException

ExecutionException

join_void_fork_loop

public <T> void join_void_fork_loop(Iterable<T> iterable,
 TaskConsumer<T> consumer)
                             throws InterruptedException,
ExecutionException

Specified by:

join_void_fork_loop in interface ForkJoin

Throws:

InterruptedException

ExecutionException

join_void_fork_loop_with_index

public <T> void join_void_fork_loop_with_index(T[] array,
 TaskConsumerWithIndex<T> consumerWithIndex)
                                        throws InterruptedException,
ExecutionException

Specified by:

join_void_fork_loop_with_index in interface ForkJoin

Throws:

InterruptedException

ExecutionException

join_void_fork_loop_with_index

public <T> void join_void_fork_loop_with_index(Iterable<T> iterable,
 TaskConsumerWithIndex<T> consumerWithIndex)
                                        throws InterruptedException,
ExecutionException

Specified by:

join_void_fork_loop_with_index in interface ForkJoin

Throws:

InterruptedException

ExecutionException

join_void_fork_loop_auto_coarsen

public void join_void_fork_loop_auto_coarsen(int min,
 int maxExclusive,
 TaskIntConsumer consumer)
                                      throws InterruptedException,
ExecutionException

Specified by:

join_void_fork_loop_auto_coarsen in interface ForkJoin

Throws:

InterruptedException

ExecutionException

join_void_fork_loop_2d

public void join_void_fork_loop_2d(int aMin,
 int aMaxExclusive,
 int bMin,
 int bMaxExclusive,
 TaskBiIntConsumer biConsumer)
                            throws InterruptedException,
ExecutionException

Specified by:

join_void_fork_loop_2d in interface ForkJoin

Throws:

InterruptedException

ExecutionException

join_void_fork_loop_2d_auto_coarsen

public void join_void_fork_loop_2d_auto_coarsen(int aMin,
 int aMaxExclusive,
 int bMin,
 int bMaxExclusive,
 TaskBiIntConsumer biConsumer)
                                         throws InterruptedException,
ExecutionException

Specified by:

join_void_fork_loop_2d_auto_coarsen in interface ForkJoin

Throws:

InterruptedException

ExecutionException