/libcore/luni/src/main/java/java/util/concurrent/ |
H A D | RejectedExecutionHandler.java | 29 * @param executor the executor attempting to execute this task 32 void rejectedExecution(Runnable r, ThreadPoolExecutor executor); argument
|
H A D | ExecutorCompletionService.java | 78 private final Executor executor; field in class:ExecutorCompletionService 113 * executor for base task execution and a 116 * @param executor the executor to use 117 * @throws NullPointerException if executor is {@code null} 119 public ExecutorCompletionService(Executor executor) { argument 120 if (executor == null) 122 this.executor = executor; 123 this.aes = (executor instanceo 141 ExecutorCompletionService(Executor executor, BlockingQueue<Future<V>> completionQueue) argument [all...] |
H A D | CompletionStage.java | 170 * @param executor the executor to use for asynchronous execution 176 Executor executor); 217 * @param executor the executor to use for asynchronous execution 221 Executor executor); 258 * @param executor the executor to use for asynchronous execution 262 Executor executor); 306 * supplied executor, wit 174 thenApplyAsync(Function<? super T,? extends U> fn, Executor executor) argument 220 thenAcceptAsync(Consumer<? super T> action, Executor executor) argument 261 thenRunAsync(Runnable action, Executor executor) argument 320 thenCombineAsync(CompletionStage<? extends U> other, BiFunction<? super T,? super U,? extends V> fn, Executor executor) argument 378 thenAcceptBothAsync(CompletionStage<? extends U> other, BiConsumer<? super T, ? super U> action, Executor executor) argument 427 runAfterBothAsync(CompletionStage<?> other, Runnable action, Executor executor) argument 483 applyToEitherAsync(CompletionStage<? extends T> other, Function<? super T, U> fn, Executor executor) argument 538 acceptEitherAsync(CompletionStage<? extends T> other, Consumer<? super T> action, Executor executor) argument 589 runAfterEitherAsync(CompletionStage<?> other, Runnable action, Executor executor) argument 668 thenComposeAsync(Function<? super T, ? extends CompletionStage<U>> fn, Executor executor) argument 726 handleAsync(BiFunction<? super T, Throwable, ? extends U> fn, Executor executor) argument 805 whenCompleteAsync(BiConsumer<? super T, ? super Throwable> action, Executor executor) argument [all...] |
H A D | Executors.java | 143 * {@code newFixedThreadPool(1)} the returned executor is 160 * returned executor is guaranteed not to be reconfigurable to use 216 * Creates a single-threaded executor that can schedule commands 224 * {@code newScheduledThreadPool(1)} the returned executor is 226 * @return the newly created scheduled executor 234 * Creates a single-threaded executor that can schedule commands 242 * the returned executor is guaranteed not to be reconfigurable to 246 * @return a newly created scheduled executor 271 * @param threadFactory the factory to use when the executor 284 * ExecutorService} methods to the given executor, bu 292 unconfigurableExecutorService(ExecutorService executor) argument 308 unconfigurableScheduledExecutorService(ScheduledExecutorService executor) argument 590 DelegatedExecutorService(ExecutorService executor) argument 631 FinalizableDelegatedExecutorService(ExecutorService executor) argument 647 DelegatedScheduledExecutorService(ScheduledExecutorService executor) argument [all...] |
H A D | CompletableFuture.java | 370 * Default executor -- ForkJoinPool.commonPool() unless it cannot 382 * Null-checks user executor argument, and translates uses of 484 /** A Completion with a source, dependent, and executor. */ 487 Executor executor; // executor to use (null if none) field in class:CompletableFuture.UniCompletion 491 UniCompletion(Executor executor, CompletableFuture<V> dep, argument 493 this.executor = executor; this.dep = dep; this.src = src; 503 Executor e = executor; 507 executor 548 UniApply(Executor executor, CompletableFuture<V> dep, CompletableFuture<T> src, Function<? super T,? extends V> fn) argument 604 UniAccept(Executor executor, CompletableFuture<Void> dep, CompletableFuture<T> src, Consumer<? super T> fn) argument 659 UniRun(Executor executor, CompletableFuture<Void> dep, CompletableFuture<T> src, Runnable fn) argument 707 UniWhenComplete(Executor executor, CompletableFuture<T> dep, CompletableFuture<T> src, BiConsumer<? super T, ? super Throwable> fn) argument 770 UniHandle(Executor executor, CompletableFuture<V> dep, CompletableFuture<T> src, BiFunction<? super T, Throwable, ? extends V> fn) argument 923 UniCompose(Executor executor, CompletableFuture<V> dep, CompletableFuture<T> src, Function<? super T, ? extends CompletionStage<V>> fn) argument 1013 BiCompletion(Executor executor, CompletableFuture<V> dep, CompletableFuture<T> src, CompletableFuture<U> snd) argument 1066 BiApply(Executor executor, CompletableFuture<V> dep, CompletableFuture<T> src, CompletableFuture<U> snd, BiFunction<? super T,? super U,? extends V> fn) argument 1137 BiAccept(Executor executor, CompletableFuture<Void> dep, CompletableFuture<T> src, CompletableFuture<U> snd, BiConsumer<? super T,? super U> fn) argument 1209 BiRun(Executor executor, CompletableFuture<Void> dep, CompletableFuture<T> src, CompletableFuture<U> snd, Runnable fn) argument 1345 OrApply(Executor executor, CompletableFuture<V> dep, CompletableFuture<T> src, CompletableFuture<U> snd, Function<? super T,? extends V> fn) argument 1409 OrAccept(Executor executor, CompletableFuture<Void> dep, CompletableFuture<T> src, CompletableFuture<U> snd, Consumer<? super T> fn) argument 1473 OrRun(Executor executor, CompletableFuture<Void> dep, CompletableFuture<T> src, CompletableFuture<U> snd, Runnable fn) argument 1825 supplyAsync(Supplier<U> supplier, Executor executor) argument 1853 runAsync(Runnable runnable, Executor executor) argument 1988 thenApplyAsync( Function<? super T,? extends U> fn, Executor executor) argument 2001 thenAcceptAsync(Consumer<? super T> action, Executor executor) argument 2014 thenRunAsync(Runnable action, Executor executor) argument 2031 thenCombineAsync( CompletionStage<? extends U> other, BiFunction<? super T,? super U,? extends V> fn, Executor executor) argument 2049 thenAcceptBothAsync( CompletionStage<? extends U> other, BiConsumer<? super T, ? super U> action, Executor executor) argument 2065 runAfterBothAsync(CompletionStage<?> other, Runnable action, Executor executor) argument 2081 applyToEitherAsync( CompletionStage<? extends T> other, Function<? super T, U> fn, Executor executor) argument 2097 acceptEitherAsync( CompletionStage<? extends T> other, Consumer<? super T> action, Executor executor) argument 2113 runAfterEitherAsync(CompletionStage<?> other, Runnable action, Executor executor) argument 2129 thenComposeAsync( Function<? super T, ? extends CompletionStage<U>> fn, Executor executor) argument 2145 whenCompleteAsync( BiConsumer<? super T, ? super Throwable> action, Executor executor) argument 2160 handleAsync( BiFunction<? super T, Throwable, ? extends U> fn, Executor executor) argument 2455 completeAsync(Supplier<? extends T> supplier, Executor executor) argument 2542 delayedExecutor(long delay, TimeUnit unit, Executor executor) argument 2650 final Executor executor; field in class:CompletableFuture.DelayedExecutor 2651 DelayedExecutor(long delay, TimeUnit unit, Executor executor) argument 2661 final Executor executor; field in class:CompletableFuture.TaskSubmitter 2663 TaskSubmitter(Executor executor, Runnable action) argument 2735 completeAsync(Supplier<? extends T> supplier, Executor executor) argument [all...] |
/libcore/ojluni/src/main/java/sun/nio/ch/ |
H A D | ThreadPool.java | 51 private final ExecutorService executor; field in class:ThreadPool 60 private ThreadPool(ExecutorService executor, argument 64 this.executor = executor; 69 ExecutorService executor() { method in class:ThreadPool 70 return executor; 105 ExecutorService executor = 110 return new ThreadPool(executor, false, initialSize); 117 ExecutorService executor = Executors.newFixedThreadPool(nThreads, factory); 118 return new ThreadPool(executor, tru 122 wrap(ExecutorService executor, int initialSize) argument [all...] |
/libcore/luni/src/test/java/tests/security/ |
H A D | SecureRandomTest.java | 79 ExecutorService executor = Executors.newFixedThreadPool(threads); 80 ExecutorCompletionService ecs = new ExecutorCompletionService(executor); 91 executor.shutdown();
|
/libcore/support/src/test/java/libcore/javax/net/ssl/ |
H A D | TestSSLSocketPair.java | 79 ExecutorService executor = Executors.newFixedThreadPool(2); 80 Future s = executor.submit(new Callable<Void>() { 89 Future c = executor.submit(new Callable<Void>() { 98 executor.shutdown();
|
/libcore/luni/src/test/java/libcore/javax/net/ssl/ |
H A D | SSLSocketTest.java | 351 ExecutorService executor = Executors.newSingleThreadExecutor(); 352 Future<Void> future = executor.submit(new Callable<Void>() { 373 executor.shutdown(); 405 final ExecutorService executor = Executors.newSingleThreadExecutor(); 410 final Future<byte[]> future1 = executor.submit(new SSLServerSessionIdCallable(server1)); 423 final Future<byte[]> future2 = executor.submit(new SSLServerSessionIdCallable(server2)); 435 executor.shutdown(); 446 ExecutorService executor = Executors.newSingleThreadExecutor(); 447 Future<Void> future = executor.submit(new Callable<Void>() { 458 executor [all...] |
/libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/io/ |
H A D | OutputStreamTesterTest.java | 116 private ExecutorService executor; field in class:OutputStreamTesterTest.PipedOutputStreamSinkTester 123 executor = Executors.newSingleThreadExecutor(); 124 future = executor.submit(new Callable<byte[]>() { 141 executor.shutdown();
|
H A D | WriterTesterTest.java | 109 private ExecutorService executor; field in class:WriterTesterTest.PipedWriterCharSinkTester 116 executor = Executors.newSingleThreadExecutor(); 117 future = executor.submit(new Callable<char[]>() { 135 executor.shutdown();
|
/libcore/luni/src/test/java/libcore/java/lang/ref/ |
H A D | ReferenceQueueTest.java | 124 ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(1); 125 executor.schedule(runnable, delayMillis, TimeUnit.MILLISECONDS); 126 executor.shutdown();
|
/libcore/luni/src/test/java/libcore/java/util/zip/ |
H A D | DeflaterOutputStreamTest.java | 72 ExecutorService executor = Executors.newSingleThreadExecutor(); 76 executor.submit(new Callable<Void>() { 93 executor.shutdown();
|
/libcore/jsr166-tests/src/test/java/jsr166/ |
H A D | SynchronousQueueTest.java | 481 final ExecutorService executor = Executors.newFixedThreadPool(2); 482 try (PoolCleaner cleaner = cleaner(executor)) { 484 executor.execute(new CheckedRunnable() { 492 executor.execute(new CheckedRunnable() { 508 final ExecutorService executor = Executors.newFixedThreadPool(2); 509 try (PoolCleaner cleaner = cleaner(executor)) { 510 executor.execute(new CheckedRunnable() { 518 executor.execute(new CheckedRunnable() {
|
H A D | ExecutorsTest.java | 290 for (final ExecutorService executor : executors) { 293 Future future = executor.submit(sleeper); 299 for (ExecutorService executor : executors) 300 joinPool(executor);
|
H A D | ArrayBlockingQueueTest.java | 797 final ExecutorService executor = Executors.newFixedThreadPool(2); 798 try (PoolCleaner cleaner = cleaner(executor)) { 799 executor.execute(new CheckedRunnable() { 807 executor.execute(new CheckedRunnable() { 822 final ExecutorService executor = Executors.newFixedThreadPool(2); 823 try (PoolCleaner cleaner = cleaner(executor)) { 824 executor.execute(new CheckedRunnable() { 832 executor.execute(new CheckedRunnable() {
|
H A D | LinkedBlockingQueueTest.java | 731 final ExecutorService executor = Executors.newFixedThreadPool(2); 732 try (PoolCleaner cleaner = cleaner(executor)) { 733 executor.execute(new CheckedRunnable() { 741 executor.execute(new CheckedRunnable() { 755 final ExecutorService executor = Executors.newFixedThreadPool(2); 756 try (PoolCleaner cleaner = cleaner(executor)) { 757 executor.execute(new CheckedRunnable() { 765 executor.execute(new CheckedRunnable() {
|
H A D | LinkedTransferQueueTest.java | 603 final ExecutorService executor = Executors.newFixedThreadPool(2); 604 try (PoolCleaner cleaner = cleaner(executor)) { 606 executor.execute(new CheckedRunnable() { 614 executor.execute(new CheckedRunnable() { 629 final ExecutorService executor = Executors.newFixedThreadPool(2); 630 try (PoolCleaner cleaner = cleaner(executor)) { 632 executor.execute(new CheckedRunnable() { 642 executor.execute(new CheckedRunnable() {
|
H A D | PriorityBlockingQueueTest.java | 632 final ExecutorService executor = Executors.newFixedThreadPool(2); 633 try (PoolCleaner cleaner = cleaner(executor)) { 634 executor.execute(new CheckedRunnable() { 642 executor.execute(new CheckedRunnable() {
|
H A D | LinkedBlockingDequeTest.java | 1685 final ExecutorService executor = Executors.newFixedThreadPool(2); 1686 try (PoolCleaner cleaner = cleaner(executor)) { 1687 executor.execute(new CheckedRunnable() { 1695 executor.execute(new CheckedRunnable() { 1709 final ExecutorService executor = Executors.newFixedThreadPool(2); 1710 try (PoolCleaner cleaner = cleaner(executor)) { 1711 executor.execute(new CheckedRunnable() { 1719 executor.execute(new CheckedRunnable() {
|
H A D | DelayQueueTest.java | 675 final ExecutorService executor = Executors.newFixedThreadPool(2); 676 try (PoolCleaner cleaner = cleaner(executor)) { 677 executor.execute(new CheckedRunnable() { 685 executor.execute(new CheckedRunnable() {
|
/libcore/tzdata/update_test_app/src/libcore/tzdata/update_test_app/installupdatetestapp/ |
H A D | MainActivity.java | 54 private ExecutorService executor; field in class:MainActivity 69 executor = Executors.newFixedThreadPool(1); 114 }.executeOnExecutor(executor);
|
/libcore/support/src/test/java/tests/http/ |
H A D | MockWebServer.java | 77 private ExecutorService executor; field in class:MockWebServer 177 executor = Executors.newCachedThreadPool(); 182 executor.execute(namedRunnable("MockWebServer-accept-" + port, new Runnable() { 208 executor.shutdown(); 210 logger.log(Level.WARNING, "MockWebServer executor shutdown failed", e); 243 executor.execute(namedRunnable(name, new Runnable() {
|
/libcore/luni/src/test/java/libcore/java/net/ |
H A D | SocketTest.java | 457 private ExecutorService executor; field in class:SocketTest.MockServer 462 executor = Executors.newCachedThreadPool(); 470 return executor.submit(new Callable<byte[]>() { 490 executor.shutdown();
|
/libcore/luni/src/test/java/libcore/java/util/concurrent/ |
H A D | CopyOnWriteArrayListTest.java | 180 ExecutorService executor = Executors.newSingleThreadExecutor(); 181 Future<?> future = executor.submit(new Runnable() { 190 executor.shutdown();
|