Searched refs:executor (Results 1 - 25 of 29) sorted by relevance

12

/libcore/luni/src/main/java/java/util/concurrent/
H A DRejectedExecutionHandler.java29 * @param executor the executor attempting to execute this task
32 void rejectedExecution(Runnable r, ThreadPoolExecutor executor); argument
H A DExecutorCompletionService.java78 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 DCompletionStage.java170 * @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 DExecutors.java143 * {@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 DCompletableFuture.java370 * 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 DThreadPool.java51 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 DSecureRandomTest.java79 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 DTestSSLSocketPair.java79 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 DSSLSocketTest.java351 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 DOutputStreamTesterTest.java116 private ExecutorService executor; field in class:OutputStreamTesterTest.PipedOutputStreamSinkTester
123 executor = Executors.newSingleThreadExecutor();
124 future = executor.submit(new Callable<byte[]>() {
141 executor.shutdown();
H A DWriterTesterTest.java109 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 DReferenceQueueTest.java124 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 DDeflaterOutputStreamTest.java72 ExecutorService executor = Executors.newSingleThreadExecutor();
76 executor.submit(new Callable<Void>() {
93 executor.shutdown();
/libcore/jsr166-tests/src/test/java/jsr166/
H A DSynchronousQueueTest.java481 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 DExecutorsTest.java290 for (final ExecutorService executor : executors) {
293 Future future = executor.submit(sleeper);
299 for (ExecutorService executor : executors)
300 joinPool(executor);
H A DArrayBlockingQueueTest.java797 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 DLinkedBlockingQueueTest.java731 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 DLinkedTransferQueueTest.java603 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 DPriorityBlockingQueueTest.java632 final ExecutorService executor = Executors.newFixedThreadPool(2);
633 try (PoolCleaner cleaner = cleaner(executor)) {
634 executor.execute(new CheckedRunnable() {
642 executor.execute(new CheckedRunnable() {
H A DLinkedBlockingDequeTest.java1685 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 DDelayQueueTest.java675 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 DMainActivity.java54 private ExecutorService executor; field in class:MainActivity
69 executor = Executors.newFixedThreadPool(1);
114 }.executeOnExecutor(executor);
/libcore/support/src/test/java/tests/http/
H A DMockWebServer.java77 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 DSocketTest.java457 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 DCopyOnWriteArrayListTest.java180 ExecutorService executor = Executors.newSingleThreadExecutor();
181 Future<?> future = executor.submit(new Runnable() {
190 executor.shutdown();

Completed in 922 milliseconds

12