public class ForkJoinPool
extends java.lang.Object
| Constructor and Description |
|---|
ForkJoinPool(Environment env) |
ForkJoinPool(Environment env,
Dispatcher dispatcher,
java.util.concurrent.Executor executor) |
| 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(). |
public ForkJoinPool(Environment env)
public ForkJoinPool(Environment env, Dispatcher dispatcher, java.util.concurrent.Executor executor)
public <V> ForkJoinTask<com.gs.collections.api.list.ImmutableList<V>,Promise<com.gs.collections.api.list.ImmutableList<V>>> join(Function<?,V>... tasks)
Executor
and collecting the results in a List that will be the fulfillment of the Promise returned from ForkJoinTask.compose().V - type of task resulttasks - asynchronous tasks to executepublic <V> ForkJoinTask<com.gs.collections.api.list.ImmutableList<V>,Promise<com.gs.collections.api.list.ImmutableList<V>>> join(java.util.Collection<Function<?,V>> tasks)
Executor
and collecting the results in a List that will be the fulfillment of the Promise returned from ForkJoinTask.compose().V - type of task resulttasks - asynchronous tasks to executepublic <V> ForkJoinTask<V,Stream<V>> fork()
ForkJoinTask and publish the non-null
results, one per task, to the Stream returned from ForkJoinTask.compose().V - type of task result