reactor.core.fork

Class ForkJoinTask<T,C extends Composable<T>>

java.lang.Object

reactor.core.fork.ForkJoinTask<T,C>

All Implemented Interfaces:

Consumer<java.lang.Object>

public class ForkJoinTask<T,C extends Composable<T>>
extends java.lang.Object
implements Consumer<java.lang.Object>

Represents a collection of asynchronous tasks that will be executed once per submit().

Method Summary

Modifier and Type	Method and Description
void	accept(java.lang.Object arg) Execute the logic of the action, accepting the given parameter.
<V> ForkJoinTask<T,C>	add(Function<V,T> fn) Add a task to the collection of tasks to be executed.
C	compose() Compose actions against the asynchronous results.
com.gs.collections.api.list.MutableList<Function<?,?>>	getTasks() Get the MutableList of tasks that will be submitted when submit(Object) is called.
void	submit() Submit all configured tasks, possibly in parallel (depending on the configuration of the Executor in use), passing null as an input parameter.
<V> void	submit(V arg) Submit all configured tasks, possibly in parallel (depending on the configuration of the Executor in use), passing arg as an input parameter.

Methods inherited from class java.lang.Object

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

Method Detail

getTasks

public com.gs.collections.api.list.MutableList<Function<?,?>> getTasks()

Get the MutableList of tasks that will be submitted when submit(Object) is called.

Returns:

add

public <V> ForkJoinTask<T,C> add(Function<V,T> fn)

Add a task to the collection of tasks to be executed.

Type Parameters:

V - type of result

Parameters:

fn - task to submit

Returns:

this

compose

public C compose()

Compose actions against the asynchronous results.

Returns:

Promise or a Stream depending on the implementation.

submit

public void submit()

Submit all configured tasks, possibly in parallel (depending on the configuration of the Executor in use), passing null as an input parameter.

submit

public <V> void submit(V arg)

Submit all configured tasks, possibly in parallel (depending on the configuration of the Executor in use), passing arg as an input parameter.

Type Parameters:

V - type of input parameter

Parameters:

arg - input parameter

accept

public void accept(java.lang.Object arg)

Description copied from interface: Consumer

Execute the logic of the action, accepting the given parameter.

Specified by:

accept in interface Consumer<java.lang.Object>

Parameters:

arg - The parameter to pass to the consumer.