reactor.core.fork

Class ForkJoinPool

java.lang.Object

reactor.core.fork.ForkJoinPool

public class ForkJoinPool
extends java.lang.Object

Simple Executor backed fork/join pool that will coalesce results from asynchronous tasks and publish them into a Promise or a Stream depending on whether you intend to fork() an execution or join() them together. tasks

Constructor Summary

Constructors

Constructor and Description
ForkJoinPool(Environment env)
ForkJoinPool(Environment env, Dispatcher dispatcher, java.util.concurrent.Executor executor)

Method Summary

Modifier and Type	Method and Description
<V> ForkJoinTask<V,Stream<V>>	fork() Asynchronously execute tasks added to the returned ForkJoinTask and publish the non-null results, one per task, to the Stream returned from ForkJoinTask.compose().
<V> ForkJoinTask<com.gs.collections.api.list.ImmutableList<V>,Promise<com.gs.collections.api.list.ImmutableList<V>>>	join(java.util.Collection<Function<?,V>> tasks) Asynchronously submit the given tasks, one submit per task, to the configured Executor and collecting the results in a List that will be the fulfillment of the Promise returned from ForkJoinTask.compose().
<V> ForkJoinTask<com.gs.collections.api.list.ImmutableList<V>,Promise<com.gs.collections.api.list.ImmutableList<V>>>	join(Function<?,V>... tasks) Asynchronously submit the given tasks, one submit per task, to the configured Executor and collecting the results in a List that will be the fulfillment of the Promise returned from ForkJoinTask.compose().

Methods inherited from class java.lang.Object

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

Constructor Detail

ForkJoinPool

public ForkJoinPool(Environment env)

ForkJoinPool

public ForkJoinPool(Environment env,
                    Dispatcher dispatcher,
                    java.util.concurrent.Executor executor)

Method Detail

join

public <V> ForkJoinTask<com.gs.collections.api.list.ImmutableList<V>,Promise<com.gs.collections.api.list.ImmutableList<V>>> join(Function<?,V>... tasks)

Asynchronously submit the given tasks, one submit per task, to the configured Executor and collecting the results in a List that will be the fulfillment of the Promise returned from ForkJoinTask.compose().

Type Parameters:

V - type of task result

Parameters:

tasks - asynchronous tasks to execute

Returns:

fork/join task

join

public <V> ForkJoinTask<com.gs.collections.api.list.ImmutableList<V>,Promise<com.gs.collections.api.list.ImmutableList<V>>> join(java.util.Collection<Function<?,V>> tasks)

Asynchronously submit the given tasks, one submit per task, to the configured Executor and collecting the results in a List that will be the fulfillment of the Promise returned from ForkJoinTask.compose().

Type Parameters:

V - type of task result

Parameters:

tasks - asynchronous tasks to execute

Returns:

fork/join task

fork

public <V> ForkJoinTask<V,Stream<V>> fork()

Asynchronously execute tasks added to the returned ForkJoinTask and publish the non-null results, one per task, to the Stream returned from ForkJoinTask.compose().

Type Parameters:

V - type of task result

Returns:

fork/join task