Uses of Interface
com.oracle.coherence.concurrent.executor.Task.Collector
Packages that use 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
Classes in com.oracle.coherence.concurrent.executor that implement Task.CollectorModifier 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
.Methods in com.oracle.coherence.concurrent.executor that return Task.CollectorModifier 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.Methods in com.oracle.coherence.concurrent.executor with parameters of type Task.CollectorModifier 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.