Uses of Interface
com.oracle.coherence.concurrent.executor.Task.Collector
Package
Description
Classes to allow submission of tasks to the grid for execution.
-
Uses of Task.Collector in com.oracle.coherence.concurrent.executor
Modifier and TypeClassDescriptionclass
com.oracle.coherence.concurrent.executor.AbstractCollector<T,
R> An abstractTask.Collector
.static class
ATask.Collector
that counts the number of results are present.static class
ATask.Collector
to collect any (the first provided) available result.static class
ATask.Collector
that collects and returns the last contributed result.static class
ATask.Collector
that collects and returns all contributed results that are values as aList
.static class
ATask.Collector
that collects and returns all contributed results that are values as aSet
.Modifier and TypeMethodDescriptionstatic <T> Task.Collector
<? super T, ?, Integer> TaskCollectors.count()
ATask.Collector
that counts the number of non-null results that have been made.static <T> Task.Collector
<T, ?, T> TaskCollectors.firstOf()
ATask.Collector
that will collect the first provided result.static <T> Task.Collector
<T, ?, T> TaskCollectors.lastOf()
ATask.Collector
that returns the last added result, when all results have been provided.static <T> Task.Collector
<T, ?, List<T>> TaskCollectors.listOf()
ATask.Collector
that returns theList
of results that are values.static <T> Task.Collector
<T, ?, Set<T>> TaskCollectors.setOf()
ATask.Collector
that returns theSet
of results that are values.Modifier and TypeMethodDescription<R> Task.Collectable
<T, R> Task.Orchestration.collect
(Task.Collector<? super T, ?, R> collector) Creates aTask.Collectable
for theTask
using the specifiedTask.Collector
, that will collect individual results fromTask
s when they are executed with orchestratedExecutor
s.