Home
last modified time | relevance | path

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

/libcore/ojluni/src/main/java/java/util/concurrent/
DCompletionStage.java207 Executor executor); in thenApplyAsync()
252 Executor executor); in thenAcceptAsync()
293 Executor executor); in thenRunAsync()
354 Executor executor); in thenCombineAsync()
412 Executor executor); in thenAcceptBothAsync()
460 Executor executor); in runAfterBothAsync()
517 Executor executor); in applyToEitherAsync()
572 Executor executor); in acceptEitherAsync()
623 Executor executor); in runAfterEitherAsync()
701 Executor executor); in thenComposeAsync()
[all …]
DCompletableFuture.java413 private static final Executor ASYNC_POOL = USE_COMMON_POOL ?
417 private static final class ThreadPerTaskExecutor implements Executor {
428 static Executor screenExecutor(Executor e) { in screenExecutor()
527 Executor executor; // executor to use (null if none)
531 UniCompletion(Executor executor, CompletableFuture<V> dep, in UniCompletion()
543 Executor e = executor; in claim()
598 UniApply(Executor executor, CompletableFuture<V> dep, in UniApply()
634 Executor e, Function<? super T,? extends V> f) { in uniApplyStage()
645 Object r, Executor e, Function<? super T,? extends V> f) { in uniApplyNow()
671 UniAccept(Executor executor, CompletableFuture<Void> dep, in UniAccept()
[all …]
DExecutorCompletionService.java106 private final Executor executor;
147 public ExecutorCompletionService(Executor executor) { in ExecutorCompletionService()
169 public ExecutorCompletionService(Executor executor, in ExecutorCompletionService()
DExecutor.java124 public interface Executor { interface
DSubmissionPublisher.java213 private static final Executor ASYNC_POOL =
218 private static final class ThreadPerTaskExecutor implements Executor {
250 final Executor executor;
274 public SubmissionPublisher(Executor executor, int maxBufferCapacity, in SubmissionPublisher()
303 public SubmissionPublisher(Executor executor, int maxBufferCapacity) { in SubmissionPublisher()
753 public Executor getExecutor() { in getExecutor()
1061 Executor executor; // null on error
1084 Executor executor, in BufferedSubscription()
1223 Executor e; in tryStart()
DExecutorService.java153 public interface ExecutorService extends Executor, AutoCloseable {
DForkJoinPool.java2421 static void helpAsyncBlocker(Executor e, ManagedBlocker blocker) {
/libcore/ojluni/annotations/flagged_api/java/util/concurrent/
DCompletableFuture.annotated.java48 …er, java.util.function.Consumer<? super T> action, java.util.concurrent.Executor executor) { throw… in acceptEitherAsync()
58 …ther, java.util.function.Function<? super T,U> fn, java.util.concurrent.Executor executor) { throw… in applyToEitherAsync()
66 …java.util.function.Supplier<? extends T> supplier, java.util.concurrent.Executor executor) { throw… in completeAsync()
78 public java.util.concurrent.Executor defaultExecutor() { throw new RuntimeException("Stub!"); } in defaultExecutor()
80 public static java.util.concurrent.Executor delayedExecutor(long delay, java.util.concurrent.TimeUn… in delayedExecutor()
82 …tic java.util.concurrent.Executor delayedExecutor(long delay, java.util.concurrent.TimeUnit unit, … in delayedExecutor()
91 …tion.Function<java.lang.Throwable,? extends T> fn, java.util.concurrent.Executor executor) { throw… in exceptionallyAsync()
97 …tends java.util.concurrent.CompletionStage<T>> fn, java.util.concurrent.Executor executor) { throw… in exceptionallyComposeAsync()
115 …ion<? super T,java.lang.Throwable,? extends U> fn, java.util.concurrent.Executor executor) { throw… in handleAsync()
142 …mpletionStage<?> other, java.lang.Runnable action, java.util.concurrent.Executor executor) { throw… in runAfterBothAsync()
[all …]
DExecutorService.annotated.java40 public interface ExecutorService extends java.lang.AutoCloseable, java.util.concurrent.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/luni/src/test/java/libcore/java/util/concurrent/
DCompletionStageTest.java26 import java.util.concurrent.Executor;
43 private Executor executor = null;
52 BaseStage(Executor executor) { in BaseStage()
109 Executor executor) { in thenApplyAsync()
122 Executor executor) { in thenAcceptAsync()
135 Executor executor) { in thenRunAsync()
151 Executor executor) { in thenCombineAsync()
167 Executor executor) { in thenAcceptBothAsync()
183 Executor executor) { in runAfterBothAsync()
199 Executor executor) { in applyToEitherAsync()
[all …]
/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/src/test/java/util/concurrent/tck/
DExecutorCompletionService9Test.java54 import java.util.concurrent.Executor;
74 void solveAll(Executor e, in solveAll()
87 void solveAny(Executor e, in solveAny()
DSubmissionPublisherTest.java47 import java.util.concurrent.Executor;
74 final Executor basicExecutor = basicPublisher().getExecutor();
196 Executor e = p.getExecutor(), c = ForkJoinPool.commonPool(); in testConstructor1()
209 Executor e = Executors.newFixedThreadPool(1); in testConstructor2()
234 Executor e = Executors.newFixedThreadPool(1); in testConstructor4()
DCompletableFutureTest.java68 import java.util.concurrent.Executor;
633 static class CountingRejectingExecutor implements Executor {
643 static final class ThreadExecutor implements Executor {
3874 Executor e = f.defaultExecutor(); in testDefaultExecutor()
3875 Executor c = ForkJoinPool.commonPool(); in testDefaultExecutor()
4147 private void testDelayedExecutor(Executor executor, Item v) throws Exception { in testDelayedExecutor()
4151 final Executor delayer, longDelayer; in testDelayedExecutor()
4850 Executor executor) { in thenRunAsync()
4860 Executor executor) { in thenAcceptAsync()
4870 Executor executor) { in thenApplyAsync()
[all …]
/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/
DInvoker.java236 Executor executor) in invokeIndirectly()
DAsynchronousChannelGroupImpl.java47 extends AsynchronousChannelGroup implements Executor
/libcore/jsr166-tests/src/test/java/jsr166/
DCompletableFutureTest.java32 import java.util.concurrent.Executor;
559 static final class ThreadExecutor implements Executor {
3371 Executor e = f.defaultExecutor(); in testDefaultExecutor()
3372 Executor c = ForkJoinPool.commonPool(); in testDefaultExecutor()
3611 public void testDelayedExecutor(Executor executor, Integer v) throws Exception { in testDelayedExecutor()
3615 final Executor delayer, longDelayer; in testDelayedExecutor()
/libcore/api/
Dcurrent.txt15542 …mpletionStage<? extends T>, java.util.function.Consumer<? super T>, java.util.concurrent.Executor);
15547 …letionStage<? extends T>, java.util.function.Function<? super T,U>, java.util.concurrent.Executor);
15550 …leFuture<T> completeAsync(java.util.function.Supplier<? extends T>, java.util.concurrent.Executor);
15557 method public java.util.concurrent.Executor defaultExecutor();
15558 …ic static java.util.concurrent.Executor delayedExecutor(long, java.util.concurrent.TimeUnit, java.…
15559 …method public static java.util.concurrent.Executor delayedExecutor(long, java.util.concurrent.Time…
15563 …Async(java.util.function.Function<java.lang.Throwable,? extends T>, java.util.concurrent.Executor);
15566 ….lang.Throwable,? extends java.util.concurrent.CompletionStage<T>>, java.util.concurrent.Executor);
15575 …til.function.BiFunction<? super T,java.lang.Throwable,? extends U>, java.util.concurrent.Executor);
15588 …unAfterBothAsync(java.util.concurrent.CompletionStage<?>, Runnable, java.util.concurrent.Executor);
[all …]
/libcore/
Dopenjdk_java_files.bp1001 "ojluni/src/main/java/java/util/concurrent/Executor.java",
DEXPECTED_UPSTREAM1054 …ain/java/java/util/concurrent/Executor.java,jdk21u/jdk-21.0.4-ga,src/java.base/share/classes/java/…