Package fj.api

Interface ForkJoin

All Known Implementing Classes:

AbstractDecoratingFunnelingForkJoin, AbstractForkJoin, AbstractFunnelingForkJoin, ComputationGraphForkJoin, ExclusionForkJoin, ExecutorForkJoin, ImpartialForkJoin, LinearForkJoin

public interface ForkJoin

Author:

Dennis Cosgrove

Method Summary

Modifier and Type	Method	Description
<R> Future<R>	fork(TaskSupplier<R> supplier)
<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)
<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> intFunction)
<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)
<T> Future<Void>[]	void_fork_loop(int min, int maxExclusive, TaskIntConsumer consumer)
<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)

Method Details

fork

<R> Future<R> fork(TaskSupplier<R> supplier)

void_fork

Future<Void> void_fork(TaskRunnable runnable)

join

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

Throws:

InterruptedException

ExecutionException

join

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

Throws:

InterruptedException

ExecutionException

join

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

Throws:

InterruptedException

ExecutionException

join

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

Throws:

InterruptedException

ExecutionException

join

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

Throws:

InterruptedException

ExecutionException

join

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

Throws:

InterruptedException

ExecutionException

fork_loop

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

fork_loop

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

fork_loop

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

fork_loop_with_index

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

fork_loop_with_index

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

void_fork_loop

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

void_fork_loop

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

void_fork_loop

<T> Future<Void>[] void_fork_loop(int min,
 int maxExclusive,
 TaskIntConsumer consumer)

void_fork_loop_with_index

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

void_fork_loop_with_index

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

join_fork_loop

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

Throws:

InterruptedException

ExecutionException

join_fork_loop

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

Throws:

InterruptedException

ExecutionException

join_fork_loop

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

Throws:

InterruptedException

ExecutionException

join_fork_loop

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

Throws:

InterruptedException

ExecutionException

join_fork_loop

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

Throws:

InterruptedException

ExecutionException

join_fork_loop_with_index

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

Throws:

InterruptedException

ExecutionException

join_fork_loop_with_index

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

Throws:

InterruptedException

ExecutionException

join_fork_loop_with_index

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

Throws:

InterruptedException

ExecutionException

join_void_fork_loop

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

Throws:

InterruptedException

ExecutionException

join_void_fork_loop

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

Throws:

InterruptedException

ExecutionException

join_void_fork_loop

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

Throws:

InterruptedException

ExecutionException

join_void_fork_loop_with_index

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

Throws:

InterruptedException

ExecutionException

join_void_fork_loop_with_index

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

Throws:

InterruptedException

ExecutionException

join_void_fork_loop_auto_coarsen

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

Throws:

InterruptedException

ExecutionException

join_void_fork_loop_2d

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

Throws:

InterruptedException

ExecutionException

join_void_fork_loop_2d_auto_coarsen

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

Throws:

InterruptedException

ExecutionException