Home
last modified time | relevance | path

Searched defs:executor (Results 1 – 25 of 44) sorted by relevance

12

/libcore/ojluni/src/main/java/sun/nio/ch/
DThreadPool.java43 private final ExecutorService executor; field in ThreadPool
52 private ThreadPool(ExecutorService executor, in ThreadPool()
61 ExecutorService executor() { in executor() method in ThreadPool
121 ExecutorService executor = Executors.newCachedThreadPool(threadFactory); in createDefault() local
129 ExecutorService executor = Executors.newFixedThreadPool(nThreads, factory); in create() local
134 public static ThreadPool wrap(ExecutorService executor, int initialSize) { in wrap()
DAsynchronousFileChannelImpl.java55 protected final ExecutorService executor; field in AsynchronousFileChannelImpl
60 ExecutorService executor) in AsynchronousFileChannelImpl()
68 final ExecutorService executor() { in executor() method in AsynchronousFileChannelImpl
DLinuxAsynchronousChannelProvider.java61 …public AsynchronousChannelGroup openAsynchronousChannelGroup(ExecutorService executor, int initial… in openAsynchronousChannelGroup()
DAsynchronousChannelGroupImpl.java91 final ExecutorService executor() { in executor() method in AsynchronousChannelGroupImpl
DSimpleAsynchronousFileChannelImpl.java60 ExecutorService executor) in SimpleAsynchronousFileChannelImpl()
71 ExecutorService executor = (pool == null) ? in open() local
/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 …]
DExecutorCompletionService.java106 private final Executor executor; field in ExecutorCompletionService
147 public ExecutorCompletionService(Executor executor) { in ExecutorCompletionService()
169 public ExecutorCompletionService(Executor executor, in ExecutorCompletionService()
DRejectedExecutionHandler.java61 void rejectedExecution(Runnable r, ThreadPoolExecutor executor); in rejectedExecution()
DCompletableFuture.java527 Executor executor; // executor to use (null if none) field in CompletableFuture.UniCompletion
531 UniCompletion(Executor executor, CompletableFuture<V> dep, in UniCompletion()
598 UniApply(Executor executor, CompletableFuture<V> dep, in UniApply()
671 UniAccept(Executor executor, CompletableFuture<Void> dep, in UniAccept()
745 UniRun(Executor executor, CompletableFuture<Void> dep, in UniRun()
807 UniWhenComplete(Executor executor, CompletableFuture<T> dep, in UniWhenComplete()
877 UniHandle(Executor executor, CompletableFuture<V> dep, in UniHandle()
940 UniExceptionally(Executor executor, in UniExceptionally()
998 UniComposeExceptionally(Executor executor, CompletableFuture<T> dep, in UniComposeExceptionally()
1102 UniCompose(Executor executor, CompletableFuture<V> dep, in UniCompose()
[all …]
DExecutors.java360 public static ExecutorService unconfigurableExecutorService(ExecutorService executor) { in unconfigurableExecutorService()
376 …cheduledExecutorService unconfigurableScheduledExecutorService(ScheduledExecutorService executor) { in unconfigurableScheduledExecutorService()
DSubmissionPublisher.java250 final Executor executor; field in SubmissionPublisher
274 public SubmissionPublisher(Executor executor, int maxBufferCapacity, in SubmissionPublisher()
303 public SubmissionPublisher(Executor executor, int maxBufferCapacity) { in SubmissionPublisher()
1061 Executor executor; // null on error field in SubmissionPublisher.BufferedSubscription
1084 Executor executor, in BufferedSubscription()
/libcore/ojluni/annotations/flagged_api/java/util/concurrent/
DCompletableFuture.annotated.java48 …T> other, java.util.function.Consumer<? super T> action, java.util.concurrent.Executor executor) {… in acceptEitherAsync()
58 …s T> other, java.util.function.Function<? super T,U> fn, java.util.concurrent.Executor executor) {… in applyToEitherAsync()
66 …Async(java.util.function.Supplier<? extends T> supplier, java.util.concurrent.Executor executor) {… in completeAsync()
82 …Executor(long delay, java.util.concurrent.TimeUnit unit, java.util.concurrent.Executor executor) {… in delayedExecutor()
91 …l.function.Function<java.lang.Throwable,? extends T> fn, java.util.concurrent.Executor executor) {… in exceptionallyAsync()
97 …e,? extends java.util.concurrent.CompletionStage<T>> fn, java.util.concurrent.Executor executor) {… in exceptionallyComposeAsync()
115 …iFunction<? super T,java.lang.Throwable,? extends U> fn, java.util.concurrent.Executor executor) {… in handleAsync()
142 …ent.CompletionStage<?> other, java.lang.Runnable action, java.util.concurrent.Executor executor) {… in runAfterBothAsync()
148 …ent.CompletionStage<?> other, java.lang.Runnable action, java.util.concurrent.Executor executor) {… in runAfterEitherAsync()
152 …re<java.lang.Void> runAsync(java.lang.Runnable runnable, java.util.concurrent.Executor executor) {… in runAsync()
[all …]
/libcore/ojluni/annotations/mmodule/java/util/concurrent/
DCompletableFuture.annotated.java48 …<U> supplyAsync(java.util.function.Supplier<U> supplier, java.util.concurrent.Executor executor) {… in supplyAsync()
52 …re<java.lang.Void> runAsync(java.lang.Runnable runnable, java.util.concurrent.Executor executor) {… in runAsync()
74 …c(java.util.function.Function<? super T,? extends U> fn, java.util.concurrent.Executor executor) {… in thenApplyAsync()
80 …ceptAsync(java.util.function.Consumer<? super T> action, java.util.concurrent.Executor executor) {… in thenAcceptAsync()
86 …<java.lang.Void> thenRunAsync(java.lang.Runnable action, java.util.concurrent.Executor executor) {… in thenRunAsync()
92 …function.BiFunction<? super T,? super U,? extends V> fn, java.util.concurrent.Executor executor) {… in thenCombineAsync()
98 …va.util.function.BiConsumer<? super T,? super U> action, java.util.concurrent.Executor executor) {… in thenAcceptBothAsync()
104 …ent.CompletionStage<?> other, java.lang.Runnable action, java.util.concurrent.Executor executor) {… in runAfterBothAsync()
110 …s T> other, java.util.function.Function<? super T,U> fn, java.util.concurrent.Executor executor) {… in applyToEitherAsync()
116 …T> other, java.util.function.Consumer<? super T> action, java.util.concurrent.Executor executor) {… in acceptEitherAsync()
[all …]
/libcore/luni/src/test/java/libcore/java/util/concurrent/
DCompletionStageTest.java43 private Executor executor = null; field in CompletionStageTest.BaseStage
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()
215 Executor executor) { in acceptEitherAsync()
[all …]
/libcore/ojluni/src/main/java/java/nio/channels/
DAsynchronousChannelGroup.java233 public static AsynchronousChannelGroup withCachedThreadPool(ExecutorService executor, in withCachedThreadPool()
274 public static AsynchronousChannelGroup withThreadPool(ExecutorService executor) in withThreadPool()
/libcore/ojluni/annotations/hiddenapi/java/util/concurrent/
DExecutors.java102 java.util.concurrent.ExecutorService executor) { in unconfigurableExecutorService()
108 java.util.concurrent.ScheduledExecutorService executor) { in unconfigurableScheduledExecutorService()
189 DelegatedExecutorService(java.util.concurrent.ExecutorService executor) { in DelegatedExecutorService()
271 DelegatedScheduledExecutorService(java.util.concurrent.ScheduledExecutorService executor) { in DelegatedScheduledExecutorService()
315 FinalizableDelegatedExecutorService(java.util.concurrent.ExecutorService executor) { in FinalizableDelegatedExecutorService()
/libcore/luni/src/test/java/tests/security/
DSecureRandomTest.java79 ExecutorService executor = Executors.newFixedThreadPool(threads); in testSecureRandomThreadSafety() local
/libcore/support/src/test/java/libcore/javax/net/ssl/
DTestSSLSocketPair.java78 ExecutorService executor = Executors.newFixedThreadPool(2); in connect() local
/libcore/ojluni/src/test/java/lang/constant/
DDynamicConstantDescTest.java71 final ExecutorService executor = Executors.newFixedThreadPool(tasks.size()); in main() local
/libcore/luni/src/test/java/libcore/java/util/zip/
DDeflaterOutputStreamTest.java76 ExecutorService executor = Executors.newSingleThreadExecutor(); in createInflaterStream() local
/libcore/ojluni/src/test/java/security/KeyAgreement/
DMultiThreadTest.java114 ExecutorService executor = null; in runTest() local
/libcore/luni/src/test/java/libcore/java/lang/ref/
DReferenceQueueTest.java146 final ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(1); in runLater() local
/libcore/luni/src/test/java/libcore/java/nio/channels/
DServerSocketChannelTest.java168 ExecutorService executor = Executors.newSingleThreadExecutor(); in bind_loopback() local
/libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/io/
DWriterTesterTest.java109 private ExecutorService executor; field in WriterTesterTest.PipedWriterCharSinkTester
/libcore/ojluni/src/test/java/util/concurrent/tck/
DCompletableFutureTest.java4037 ThreadExecutor executor = new ThreadExecutor(); in testCompleteAsync3() local
4038 f.completeAsync(() -> v1, executor); in testCompleteAsync3() local
4052 ThreadExecutor executor = new ThreadExecutor(); in testCompleteAsync4() local
4147 private void testDelayedExecutor(Executor executor, Item v) throws Exception { in testDelayedExecutor()
4850 Executor executor) { in thenRunAsync()
4860 Executor executor) { in thenAcceptAsync()
4870 Executor executor) { in thenApplyAsync()
4883 Executor executor) { in thenCombineAsync()
4896 Executor executor) { in thenAcceptBothAsync()
4909 Executor executor) { in runAfterBothAsync()
[all …]

12