Home
last modified time | relevance | path

Searched refs:Executor (Results 1 – 16 of 16) sorted by relevance

/libcore/ojluni/src/main/java/java/util/concurrent/
DCompletionStage.java205 Executor executor); in thenApplyAsync()
250 Executor executor); in thenAcceptAsync()
291 Executor executor); in thenRunAsync()
352 Executor executor); in thenCombineAsync()
410 Executor executor); in thenAcceptBothAsync()
458 Executor executor); in runAfterBothAsync()
515 Executor executor); in applyToEitherAsync()
570 Executor executor); in acceptEitherAsync()
621 Executor executor); in runAfterEitherAsync()
699 Executor executor); in thenComposeAsync()
[all …]
DCompletableFuture.java404 private static final Executor ASYNC_POOL = USE_COMMON_POOL ?
408 static final class ThreadPerTaskExecutor implements Executor {
416 static Executor screenExecutor(Executor e) { in screenExecutor()
518 Executor executor; // executor to use (null if none)
522 UniCompletion(Executor executor, CompletableFuture<V> dep, in UniCompletion()
534 Executor e = executor; in claim()
579 UniApply(Executor executor, CompletableFuture<V> dep, in UniApply()
621 Executor e, Function<? super T,? extends V> f) { in uniApplyStage()
635 UniAccept(Executor executor, CompletableFuture<Void> dep, in UniAccept()
675 private CompletableFuture<Void> uniAcceptStage(Executor e, in uniAcceptStage()
[all …]
DExecutorCompletionService.java107 private final Executor executor;
148 public ExecutorCompletionService(Executor executor) { in ExecutorCompletionService()
170 public ExecutorCompletionService(Executor executor, in ExecutorCompletionService()
DExecutor.java126 public interface Executor { interface
DExecutorService.java142 public interface ExecutorService extends Executor {
/libcore/ojluni/annotations/mmodule/java/util/concurrent/
DCompletableFuture.annotated.java48 …pplyAsync(java.util.function.Supplier<U> supplier, java.util.concurrent.Executor executor) { throw… in supplyAsync()
52 …a.lang.Void> runAsync(java.lang.Runnable runnable, java.util.concurrent.Executor executor) { throw… in runAsync()
74 ….util.function.Function<? super T,? extends U> fn, java.util.concurrent.Executor executor) { throw… in thenApplyAsync()
80 …ync(java.util.function.Consumer<? super T> action, java.util.concurrent.Executor executor) { throw… in thenAcceptAsync()
86 …lang.Void> thenRunAsync(java.lang.Runnable action, java.util.concurrent.Executor executor) { throw… in thenRunAsync()
92 …on.BiFunction<? super T,? super U,? extends V> fn, java.util.concurrent.Executor executor) { throw… in thenCombineAsync()
98 …l.function.BiConsumer<? super T,? super U> action, java.util.concurrent.Executor executor) { throw… in thenAcceptBothAsync()
104 …mpletionStage<?> other, java.lang.Runnable action, java.util.concurrent.Executor executor) { throw… in runAfterBothAsync()
110 …ther, java.util.function.Function<? super T,U> fn, java.util.concurrent.Executor executor) { throw… in applyToEitherAsync()
116 …er, java.util.function.Consumer<? super T> action, java.util.concurrent.Executor executor) { throw… in acceptEitherAsync()
[all …]
/libcore/ojluni/src/test/java/util/concurrent/tck/
DExecutorCompletionService9Test.java45 import java.util.concurrent.Executor;
60 void solveAll(Executor e, in solveAll()
73 void solveAny(Executor e, in solveAny()
DCompletableFutureTest.java58 import java.util.concurrent.Executor;
580 static class CountingRejectingExecutor implements Executor {
590 static final class ThreadExecutor implements Executor {
3576 Executor e = f.defaultExecutor(); in testDefaultExecutor()
3577 Executor c = ForkJoinPool.commonPool(); in testDefaultExecutor()
3843 public void testDelayedExecutor(Executor executor, Integer v) throws Exception { in testDelayedExecutor()
3847 final Executor delayer, longDelayer; in testDelayedExecutor()
/libcore/ojluni/src/main/java/java/lang/
DUNIXProcess.java40 import java.util.concurrent.Executor;
118 private static final Executor processReaperExecutor =
119 doPrivileged(new PrivilegedAction<Executor>() {
120 public Executor run() {
/libcore/ojluni/annotations/hiddenapi/java/lang/
DUNIXProcess.java113 private static final java.util.concurrent.Executor processReaperExecutor;
/libcore/ojluni/src/main/java/java/sql/
DConnection.java30 import java.util.concurrent.Executor;
/libcore/ojluni/src/main/java/sun/nio/ch/
DAsynchronousChannelGroupImpl.java47 extends AsynchronousChannelGroup implements Executor
DInvoker.java236 Executor executor) in invokeIndirectly()
/libcore/jsr166-tests/src/test/java/jsr166/
DCompletableFutureTest.java32 import java.util.concurrent.Executor;
551 static final class ThreadExecutor implements Executor {
3363 Executor e = f.defaultExecutor(); in testDefaultExecutor()
3364 Executor c = ForkJoinPool.commonPool(); in testDefaultExecutor()
3603 public void testDelayedExecutor(Executor executor, Integer v) throws Exception { in testDelayedExecutor()
3607 final Executor delayer, longDelayer; in testDelayedExecutor()
/libcore/api/
Dcurrent.txt14159 …mpletionStage<? extends T>, java.util.function.Consumer<? super T>, java.util.concurrent.Executor);
14164 …letionStage<? extends T>, java.util.function.Function<? super T,U>, java.util.concurrent.Executor);
14167 …leFuture<T> completeAsync(java.util.function.Supplier<? extends T>, java.util.concurrent.Executor);
14174 method public java.util.concurrent.Executor defaultExecutor();
14175 …ic static java.util.concurrent.Executor delayedExecutor(long, java.util.concurrent.TimeUnit, java.…
14176 …method public static java.util.concurrent.Executor delayedExecutor(long, java.util.concurrent.Time…
14186 …til.function.BiFunction<? super T,java.lang.Throwable,? extends U>, java.util.concurrent.Executor);
14198 …unAfterBothAsync(java.util.concurrent.CompletionStage<?>, Runnable, java.util.concurrent.Executor);
14201 …AfterEitherAsync(java.util.concurrent.CompletionStage<?>, Runnable, java.util.concurrent.Executor);
14203 …til.concurrent.CompletableFuture<java.lang.Void> runAsync(Runnable, java.util.concurrent.Executor);
[all …]
/libcore/
Dopenjdk_java_files.bp956 "ojluni/src/main/java/java/util/concurrent/Executor.java",