|
FlexDoc/Javadoc 2.0 Demo Java Doc |
|||||||||||||
Packages that use Executor |
|
|
Utility classes commonly useful in concurrent programming.
|
|
Uses of Executor in java.util.concurrent |
Subinterfaces of Executor in java.util.concurrent |
|
interface |
|
interface |
An ExecutorService that can schedule commands to run after a given
delay, or to execute periodically.
|
Classes in java.util.concurrent that implement Executor |
|
abstract class |
Provides default implementations of ExecutorService
execution methods.
|
class |
An ExecutorService for running ForkJoinTasks.
|
class |
A ThreadPoolExecutor that can additionally schedule
commands to run after a given delay, or to execute periodically.
|
class |
An ExecutorService that executes each submitted task using
one of possibly several pooled threads, normally configured
using Executors factory methods.
|
Methods in java.util.concurrent that return Executor |
|
|
CompletableFuture.defaultExecutor()
Returns the default Executor used for async methods that do not
specify an Executor.
|
|
static Executor |
CompletableFuture.delayedExecutor(long delay, TimeUnit unit)
Returns a new Executor that submits a task to the default
executor after the given delay (or no delay if non-positive).
|
static Executor |
Returns a new Executor that submits a task to the given base
executor after the given delay (or no delay if non-positive).
|
|
SubmissionPublisher.getExecutor()
Returns the Executor used for asynchronous delivery.
|
|
Methods in java.util.concurrent with parameters of type Executor |
|
|
CompletableFuture.acceptEitherAsync(CompletionStage<? extends T> other, Consumer<? super T> action, Executor executor)
Returns a new CompletionStage that, when either this or the
other given stage complete normally, is executed using the
supplied executor, with the corresponding result as argument to
the supplied action.
|
|
|
CompletableFuture.applyToEitherAsync(CompletionStage<? extends T> other, Function<? super T,U> fn, Executor executor)
Returns a new CompletionStage that, when either this or the
other given stage complete normally, is executed using the
supplied executor, with the corresponding result as argument to
the supplied function.
|
|
|
Completes this CompletableFuture with the result of
the given Supplier function invoked from an asynchronous
task using the given executor.
|
|
static Executor |
Returns a new Executor that submits a task to the given base
executor after the given delay (or no delay if non-positive).
|
|
Returns a new CompletionStage that, when this stage completes
exceptionally, is executed with this stage's exception as the
argument to the supplied function, using the supplied Executor.
|
|
|
CompletableFuture.exceptionallyComposeAsync(Function<Throwable,? extends CompletionStage<T>> fn, Executor executor)
Returns a new CompletionStage that, when this stage completes
exceptionally, is composed using the results of the supplied
function applied to this stage's exception, using the
supplied Executor.
|
|
|
Returns a new CompletionStage that, when this stage completes
either normally or exceptionally, is executed using the
supplied executor, with this stage's result and exception as
arguments to the supplied function.
|
|
|
Returns a new CompletionStage that, when this and the other
given stage both complete normally, executes the given action
using the supplied executor.
|
|
|
Returns a new CompletionStage that, when either this or the
other given stage complete normally, executes the given action
using the supplied executor.
|
|
static CompletableFuture<Void> |
Returns a new CompletableFuture that is asynchronously completed
by a task running in the given executor after it runs the given
action.
|
|
Returns a new CompletableFuture that is asynchronously completed
by a task running in the given executor with the value obtained
by calling the given Supplier.
|
|
|
Returns a new CompletionStage that, when this stage completes
normally, is executed using the supplied Executor, with this
stage's result as the argument to the supplied action.
|
|
|
CompletableFuture.thenAcceptBothAsync(CompletionStage<? extends U> other, BiConsumer<? super T,? super U> action, Executor executor)
Returns a new CompletionStage that, when this and the other
given stage both complete normally, is executed using the
supplied executor, with the two results as arguments to the
supplied action.
|
|
|
Returns a new CompletionStage that, when this stage completes
normally, is executed using the supplied Executor, with this
stage's result as the argument to the supplied function.
|
|
|
CompletableFuture.thenCombineAsync(CompletionStage<? extends U> other, BiFunction<? super T,? super U,? extends V> fn, Executor executor)
Returns a new CompletionStage that, when this and the other
given stage both complete normally, is executed using the
supplied executor, with the two results as arguments to the
supplied function.
|
|
|
CompletableFuture.thenComposeAsync(Function<? super T,? extends CompletionStage<U>> fn, Executor executor)
Returns a new CompletionStage that is completed with the same
value as the CompletionStage returned by the given function,
executed using the supplied Executor.
|
|
|
Returns a new CompletionStage that, when this stage completes
normally, executes the given action using the supplied Executor.
|
|
|
CompletableFuture.whenCompleteAsync(BiConsumer<? super T,? super Throwable> action, Executor executor)
Returns a new CompletionStage with the same result or exception as
this stage, that executes the given action using the supplied
Executor when this stage completes.
|
|
|
CompletionStage.acceptEitherAsync(CompletionStage<? extends T> other, Consumer<? super T> action, Executor executor)
Returns a new CompletionStage that, when either this or the
other given stage complete normally, is executed using the
supplied executor, with the corresponding result as argument to
the supplied action.
|
|
|
CompletionStage.applyToEitherAsync(CompletionStage<? extends T> other, Function<? super T,U> fn, Executor executor)
Returns a new CompletionStage that, when either this or the
other given stage complete normally, is executed using the
supplied executor, with the corresponding result as argument to
the supplied function.
|
|
default CompletionStage<T> |
Returns a new CompletionStage that, when this stage completes
exceptionally, is executed with this stage's exception as the
argument to the supplied function, using the supplied Executor.
|
default CompletionStage<T> |
CompletionStage.exceptionallyComposeAsync(Function<Throwable,? extends CompletionStage<T>> fn, Executor executor)
Returns a new CompletionStage that, when this stage completes
exceptionally, is composed using the results of the supplied
function applied to this stage's exception, using the
supplied Executor.
|
|
Returns a new CompletionStage that, when this stage completes
either normally or exceptionally, is executed using the
supplied executor, with this stage's result and exception as
arguments to the supplied function.
|
|
|
Returns a new CompletionStage that, when this and the other
given stage both complete normally, executes the given action
using the supplied executor.
|
|
|
Returns a new CompletionStage that, when either this or the
other given stage complete normally, executes the given action
using the supplied executor.
|
|
|
Returns a new CompletionStage that, when this stage completes
normally, is executed using the supplied Executor, with this
stage's result as the argument to the supplied action.
|
|
|
CompletionStage.thenAcceptBothAsync(CompletionStage<? extends U> other, BiConsumer<? super T,? super U> action, Executor executor)
Returns a new CompletionStage that, when this and the other
given stage both complete normally, is executed using the
supplied executor, with the two results as arguments to the
supplied action.
|
|
|
Returns a new CompletionStage that, when this stage completes
normally, is executed using the supplied Executor, with this
stage's result as the argument to the supplied function.
|
|
|
CompletionStage.thenCombineAsync(CompletionStage<? extends U> other, BiFunction<? super T,? super U,? extends V> fn, Executor executor)
Returns a new CompletionStage that, when this and the other
given stage both complete normally, is executed using the
supplied executor, with the two results as arguments to the
supplied function.
|
|
|
CompletionStage.thenComposeAsync(Function<? super T,? extends CompletionStage<U>> fn, Executor executor)
Returns a new CompletionStage that is completed with the same
value as the CompletionStage returned by the given function,
executed using the supplied Executor.
|
|
|
Returns a new CompletionStage that, when this stage completes
normally, executes the given action using the supplied Executor.
|
|
|
CompletionStage.whenCompleteAsync(BiConsumer<? super T,? super Throwable> action, Executor executor)
Returns a new CompletionStage with the same result or exception as
this stage, that executes the given action using the supplied
Executor when this stage completes.
|
|
Constructors in java.util.concurrent with parameters of type Executor |
|
|
ExecutorCompletionService(Executor executor)
Creates an ExecutorCompletionService using the supplied
executor for base task execution and a
LinkedBlockingQueue as a completion queue.
|
|
|
Creates an ExecutorCompletionService using the supplied
executor for base task execution and the supplied queue as its
completion queue.
|
|
|
SubmissionPublisher(Executor executor, int maxBufferCapacity)
Creates a new SubmissionPublisher using the given Executor for
async delivery to subscribers, with the given maximum buffer size
for each subscriber, and no handler for Subscriber exceptions in
method onNext.
|
|
|
SubmissionPublisher(Executor executor, int maxBufferCapacity, BiConsumer<? super Flow.Subscriber<? super T>,? super Throwable> handler)
Creates a new SubmissionPublisher using the given Executor for
async delivery to subscribers, with the given maximum buffer size
for each subscriber, and, if non-null, the given handler invoked
when any Subscriber throws an exception in method onNext.
|
|
FlexDoc/Javadoc 2.0 Demo Java Doc |
|||||||||||||