Package fj.impl.funnel
Class AbstractFunnelingForkJoin
java.lang.Object
fj.impl.funnel.AbstractFunnelingForkJoin
- All Implemented Interfaces:
ForkJoin
- Direct Known Subclasses:
AbstractDecoratingFunnelingForkJoin
- Author:
- Dennis Cosgrove
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionfinal <R> Future<R>[]
fork_loop
(int min, int maxExclusive, TaskIntFunction<R> intFunction) fork_loop
(Iterable<T> iterable, TaskFunction<T, R> function) final <T,
R> Future<R>[] fork_loop
(T[] array, TaskFunction<T, R> function) fork_loop_funnel
(ForkLoopFunnel<T> funnel, TaskFunction<T, R> function) fork_loop_with_index
(Iterable<T> iterable, TaskFunctionWithIndex<T, R> functionWithIndex) final <T,
R> Future<R>[] fork_loop_with_index
(T[] array, TaskFunctionWithIndex<T, R> functionWithIndex) fork_loop_with_index_funnel
(ForkLoopFunnel<T> funnel, TaskFunctionWithIndex<T, R> functionWithIndex) final <R> List<R>
join
(Collection<Future<R>> futures) final <R> List<R>
final <R> List<R>
final <R> R[]
join
(IntFunction<R[]> returnValueArrayCreator, Future<R>[] futures) final <R> R[]
join
(IntFunction<R[]> returnValueArrayCreator, Future<R> a, Future<R> b, Future<R>... cToZ) final <R> List<R>
join_fork_loop
(int min, int maxExclusive, TaskIntFunction<R> intFunction) final <T,
R> List<R> join_fork_loop
(Iterable<T> iterable, TaskFunction<T, R> function) final <R> R[]
join_fork_loop
(IntFunction<R[]> returnValueArrayCreator, int min, int maxExclusive, TaskIntFunction<R> intFunction) final <T,
R> R[] join_fork_loop
(IntFunction<R[]> returnValueArrayCreator, T[] array, TaskFunction<T, R> function) final <T,
R> List<R> join_fork_loop
(T[] array, TaskFunction<T, R> function) final <T,
R> List<R> join_fork_loop_with_index
(Iterable<T> iterable, TaskFunctionWithIndex<T, R> functionWithIndex) final <T,
R> R[] join_fork_loop_with_index
(IntFunction<R[]> returnValueArrayCreator, T[] array, TaskFunctionWithIndex<T, R> functionWithIndex) final <T,
R> List<R> join_fork_loop_with_index
(T[] array, TaskFunctionWithIndex<T, R> functionWithIndex) protected abstract <R> List<R>
join_funnel
(JoinFunnel<R> funnel) final void
join_void_fork_loop
(int min, int maxExclusive, TaskIntConsumer consumer) final <T> void
join_void_fork_loop
(Iterable<T> iterable, TaskConsumer<T> consumer) final <T> void
join_void_fork_loop
(T[] array, TaskConsumer<T> consumer) final <T> void
join_void_fork_loop_with_index
(Iterable<T> iterable, TaskConsumerWithIndex<T> consumerWithIndex) final <T> void
join_void_fork_loop_with_index
(T[] array, TaskConsumerWithIndex<T> consumerWithIndex) void_fork_loop
(int min, int maxExclusive, TaskIntConsumer consumer) void_fork_loop
(Iterable<T> iterable, TaskConsumer<T> consumer) void_fork_loop
(T[] array, TaskConsumer<T> consumer) void_fork_loop_with_index
(Iterable<T> iterable, TaskConsumerWithIndex<T> consumerWithIndex) 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, join, join_void_fork_loop_2d, join_void_fork_loop_2d_auto_coarsen, join_void_fork_loop_auto_coarsen, void_fork
-
Constructor Details
-
AbstractFunnelingForkJoin
public AbstractFunnelingForkJoin()
-
-
Method Details
-
join_funnel
protected abstract <R> List<R> join_funnel(JoinFunnel<R> funnel) throws InterruptedException, ExecutionException -
fork_loop_funnel
protected abstract <T,R> List<Future<R>> fork_loop_funnel(ForkLoopFunnel<T> funnel, TaskFunction<T, R> function) -
fork_loop_with_index_funnel
protected abstract <T,R> List<Future<R>> fork_loop_with_index_funnel(ForkLoopFunnel<T> funnel, TaskFunctionWithIndex<T, R> functionWithIndex) -
join
- Specified by:
join
in interfaceForkJoin
- Throws:
InterruptedException
ExecutionException
-
join
public final <R> R[] join(IntFunction<R[]> returnValueArrayCreator, Future<R>[] futures) throws InterruptedException, ExecutionException - Specified by:
join
in interfaceForkJoin
- Throws:
InterruptedException
ExecutionException
-
join
public final <R> List<R> join(Future<R> a, Future<R> b, Future<R>... cToZ) throws InterruptedException, ExecutionException - Specified by:
join
in interfaceForkJoin
- Throws:
InterruptedException
ExecutionException
-
join
public final <R> R[] join(IntFunction<R[]> returnValueArrayCreator, Future<R> a, Future<R> b, Future<R>... cToZ) throws InterruptedException, ExecutionException - Specified by:
join
in interfaceForkJoin
- Throws:
InterruptedException
ExecutionException
-
join
public final <R> List<R> join(Collection<Future<R>> futures) throws InterruptedException, ExecutionException - Specified by:
join
in interfaceForkJoin
- Throws:
InterruptedException
ExecutionException
-
fork_loop
-
fork_loop
-
fork_loop
-
fork_loop_with_index
public final <T,R> List<Future<R>> fork_loop_with_index(Iterable<T> iterable, TaskFunctionWithIndex<T, R> functionWithIndex) - Specified by:
fork_loop_with_index
in interfaceForkJoin
-
fork_loop_with_index
public final <T,R> Future<R>[] fork_loop_with_index(T[] array, TaskFunctionWithIndex<T, R> functionWithIndex) - Specified by:
fork_loop_with_index
in interfaceForkJoin
-
void_fork_loop
- Specified by:
void_fork_loop
in interfaceForkJoin
-
void_fork_loop
- Specified by:
void_fork_loop
in interfaceForkJoin
-
void_fork_loop
- Specified by:
void_fork_loop
in interfaceForkJoin
-
void_fork_loop_with_index
public final <T> List<Future<Void>> void_fork_loop_with_index(Iterable<T> iterable, TaskConsumerWithIndex<T> consumerWithIndex) - Specified by:
void_fork_loop_with_index
in interfaceForkJoin
-
void_fork_loop_with_index
public final <T> Future<Void>[] void_fork_loop_with_index(T[] array, TaskConsumerWithIndex<T> consumerWithIndex) - Specified by:
void_fork_loop_with_index
in interfaceForkJoin
-
join_fork_loop
public final <R> R[] join_fork_loop(IntFunction<R[]> returnValueArrayCreator, int min, int maxExclusive, TaskIntFunction<R> intFunction) throws InterruptedException, ExecutionException - Specified by:
join_fork_loop
in interfaceForkJoin
- Throws:
InterruptedException
ExecutionException
-
join_fork_loop
public final <T,R> R[] join_fork_loop(IntFunction<R[]> returnValueArrayCreator, T[] array, TaskFunction<T, R> function) throws InterruptedException, ExecutionException- Specified by:
join_fork_loop
in interfaceForkJoin
- Throws:
InterruptedException
ExecutionException
-
join_fork_loop
public final <R> List<R> join_fork_loop(int min, int maxExclusive, TaskIntFunction<R> intFunction) throws InterruptedException, ExecutionException - Specified by:
join_fork_loop
in interfaceForkJoin
- Throws:
InterruptedException
ExecutionException
-
join_fork_loop
public final <T,R> List<R> join_fork_loop(Iterable<T> iterable, TaskFunction<T, R> function) throws InterruptedException, ExecutionException- Specified by:
join_fork_loop
in interfaceForkJoin
- Throws:
InterruptedException
ExecutionException
-
join_fork_loop
public final <T,R> List<R> join_fork_loop(T[] array, TaskFunction<T, R> function) throws InterruptedException, ExecutionException- Specified by:
join_fork_loop
in interfaceForkJoin
- Throws:
InterruptedException
ExecutionException
-
join_fork_loop_with_index
public final <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 interfaceForkJoin
- Throws:
InterruptedException
ExecutionException
-
join_fork_loop_with_index
public final <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 interfaceForkJoin
- Throws:
InterruptedException
ExecutionException
-
join_fork_loop_with_index
public final <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 interfaceForkJoin
- Throws:
InterruptedException
ExecutionException
-
join_void_fork_loop
public final void join_void_fork_loop(int min, int maxExclusive, TaskIntConsumer consumer) throws InterruptedException, ExecutionException - Specified by:
join_void_fork_loop
in interfaceForkJoin
- Throws:
InterruptedException
ExecutionException
-
join_void_fork_loop
public final <T> void join_void_fork_loop(Iterable<T> iterable, TaskConsumer<T> consumer) throws InterruptedException, ExecutionException - Specified by:
join_void_fork_loop
in interfaceForkJoin
- Throws:
InterruptedException
ExecutionException
-
join_void_fork_loop
public final <T> void join_void_fork_loop(T[] array, TaskConsumer<T> consumer) throws InterruptedException, ExecutionException - Specified by:
join_void_fork_loop
in interfaceForkJoin
- Throws:
InterruptedException
ExecutionException
-
join_void_fork_loop_with_index
public final <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 interfaceForkJoin
- Throws:
InterruptedException
ExecutionException
-
join_void_fork_loop_with_index
public final <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 interfaceForkJoin
- Throws:
InterruptedException
ExecutionException
-