Lines Matching refs:ThreadExecutor

628     static final class ThreadExecutor implements Executor {
651 assertFalse(ThreadExecutor.startedCurrentThread());
818 assertTrue(ThreadExecutor.startedCurrentThread());
821 return CompletableFuture.runAsync(a, new ThreadExecutor());
824 return CompletableFuture.supplyAsync(a, new ThreadExecutor());
828 return f.thenRunAsync(a, new ThreadExecutor());
832 return f.thenAcceptAsync(a, new ThreadExecutor());
836 return f.thenApplyAsync(a, new ThreadExecutor());
841 return f.thenComposeAsync(a, new ThreadExecutor());
846 return f.handleAsync(a, new ThreadExecutor());
851 return f.whenCompleteAsync(a, new ThreadExecutor());
855 return f.runAfterBothAsync(g, a, new ThreadExecutor());
861 return f.thenAcceptBothAsync(g, a, new ThreadExecutor());
867 return f.thenCombineAsync(g, a, new ThreadExecutor());
873 return f.runAfterEitherAsync(g, a, new ThreadExecutor());
879 return f.acceptEitherAsync(g, a, new ThreadExecutor());
885 return f.applyToEitherAsync(g, a, new ThreadExecutor());
890 return f.exceptionallyAsync(fn, new ThreadExecutor());
894 return f.exceptionallyComposeAsync(fn, new ThreadExecutor());
3466 ThreadExecutor exec = new ThreadExecutor(); in testNPE()
3926 ThreadExecutor executor = new ThreadExecutor(); in testCompleteAsync3()
3940 ThreadExecutor executor = new ThreadExecutor(); in testCompleteAsync4()
4026 () -> testDelayedExecutor(new ThreadExecutor(), 1),
4027 () -> testDelayedExecutor(new ThreadExecutor(), 1));
5080 final CompletionStage<Integer> g = d.exceptionallyComposeAsync(r, new ThreadExecutor()); in testDefaultExceptionallyComposeAsyncExecutor_normalCompletion()
5102 final CompletionStage<Integer> g = d.exceptionallyComposeAsync(r, new ThreadExecutor()); in testDefaultExceptionallyComposeAsyncExecutor_exceptionalCompletion()
5124 final CompletionStage<Integer> g = d.exceptionallyComposeAsync(r, new ThreadExecutor()); in testDefaultExceptionallyComposeAsyncExecutor_actionFailed()