Lines Matching refs:EXECUTOR
32 import java.util.concurrent.Executor;
550 // Used for explicit executor tests
551 static final class ThreadExecutor implements Executor {
720 EXECUTOR {
1207 ExecutionMode.EXECUTOR,
1224 ExecutionMode.EXECUTOR,
1240 ExecutionMode.EXECUTOR,
1258 ExecutionMode.EXECUTOR,
3283 () -> f.thenComposeAsync(new CompletableFutureInc(ExecutionMode.EXECUTOR), null),
3363 Executor e = f.defaultExecutor();
3364 Executor c = ForkJoinPool.commonPool();
3496 * completeAsync with given executor completes with value of given supplier
3502 ThreadExecutor executor = new ThreadExecutor();
3503 f.completeAsync(() -> v1, executor);
3506 assertEquals(1, executor.count.get());
3510 * completeAsync with given executor completes exceptionally if
3516 ThreadExecutor executor = new ThreadExecutor();
3517 f.completeAsync(() -> {if (true) throw ex; return 1;}, executor);
3523 assertEquals(1, executor.count.get());
3594 * delayedExecutor returns an executor that delays submission
3603 public void testDelayedExecutor(Executor executor, Integer v) throws Exception {
3607 final Executor delayer, longDelayer;
3608 if (executor == null) {
3612 delayer = CompletableFuture.delayedExecutor(timeoutMillis, MILLISECONDS, executor);
3613 longDelayer = CompletableFuture.delayedExecutor(longTimeoutMillis, MILLISECONDS, executor);
