public final class VortexThreadPool extends Object
Modifier and Type | Method and Description |
---|---|
<TInput,TOutput> |
submit(VortexAggregateFunction<TOutput> aggregateFunction,
VortexFunction<TInput,TOutput> function,
VortexAggregatePolicy policy,
List<TInput> inputs) |
<TInput,TOutput> |
submit(VortexAggregateFunction<TOutput> aggregateFunction,
VortexFunction<TInput,TOutput> function,
VortexAggregatePolicy policy,
List<TInput> inputs,
FutureCallback<AggregateResult<TInput,TOutput>> callback) |
<TInput,TOutput> |
submit(VortexFunction<TInput,TOutput> function,
TInput input) |
<TInput,TOutput> |
submit(VortexFunction<TInput,TOutput> function,
TInput input,
FutureCallback<TOutput> callback) |
public <TInput,TOutput> VortexFuture<TOutput> submit(VortexFunction<TInput,TOutput> function, TInput input)
TInput
- input typeTOutput
- output typefunction
- to run on Vortexinput
- of the functionpublic <TInput,TOutput> VortexFuture<TOutput> submit(VortexFunction<TInput,TOutput> function, TInput input, FutureCallback<TOutput> callback)
TInput
- input typeTOutput
- output typefunction
- to run on Vortexinput
- of the functioncallback
- of the functionpublic <TInput,TOutput> VortexAggregateFuture<TInput,TOutput> submit(VortexAggregateFunction<TOutput> aggregateFunction, VortexFunction<TInput,TOutput> function, VortexAggregatePolicy policy, List<TInput> inputs)
TInput
- input typeTOutput
- output typeaggregateFunction
- to run on VortexFunction outputsfunction
- to run on Vortexpolicy
- on aggregationinputs
- of the functionpublic <TInput,TOutput> VortexAggregateFuture<TInput,TOutput> submit(VortexAggregateFunction<TOutput> aggregateFunction, VortexFunction<TInput,TOutput> function, VortexAggregatePolicy policy, List<TInput> inputs, FutureCallback<AggregateResult<TInput,TOutput>> callback)
TInput
- input typeTOutput
- output typeaggregateFunction
- to run on VortexFunction outputsfunction
- to run on Vortexpolicy
- on aggregationinputs
- of the functioncallback
- of the aggregationCopyright © 2017 The Apache Software Foundation. All rights reserved.