Home
last modified time | relevance | path

Searched defs:executor (Results 1 – 25 of 41) 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.java205 Executor executor); in thenApplyAsync()
250 Executor executor); in thenAcceptAsync()
291 Executor executor); in thenRunAsync()
352 Executor executor); in thenCombineAsync()
410 Executor executor); in thenAcceptBothAsync()
458 Executor executor); in runAfterBothAsync()
515 Executor executor); in applyToEitherAsync()
570 Executor executor); in acceptEitherAsync()
621 Executor executor); in runAfterEitherAsync()
699 Executor executor); in thenComposeAsync()
[all …]
DExecutorCompletionService.java104 private final Executor executor; field in ExecutorCompletionService
145 public ExecutorCompletionService(Executor executor) { in ExecutorCompletionService()
167 public ExecutorCompletionService(Executor executor, in ExecutorCompletionService()
DRejectedExecutionHandler.java61 void rejectedExecution(Runnable r, ThreadPoolExecutor executor); in rejectedExecution()
DCompletableFuture.java523 Executor executor; // executor to use (null if none) field in CompletableFuture.UniCompletion
527 UniCompletion(Executor executor, CompletableFuture<V> dep, in UniCompletion()
594 UniApply(Executor executor, CompletableFuture<V> dep, in UniApply()
667 UniAccept(Executor executor, CompletableFuture<Void> dep, in UniAccept()
741 UniRun(Executor executor, CompletableFuture<Void> dep, in UniRun()
803 UniWhenComplete(Executor executor, CompletableFuture<T> dep, in UniWhenComplete()
873 UniHandle(Executor executor, CompletableFuture<V> dep, in UniHandle()
1024 UniCompose(Executor executor, CompletableFuture<V> dep, in UniCompose()
1107 BiCompletion(Executor executor, CompletableFuture<V> dep, in BiCompletion()
1168 BiApply(Executor executor, CompletableFuture<V> dep, in BiApply()
[all …]
DExecutors.java323 public static ExecutorService unconfigurableExecutorService(ExecutorService executor) { in unconfigurableExecutorService()
339 …cheduledExecutorService unconfigurableScheduledExecutorService(ScheduledExecutorService executor) { in unconfigurableScheduledExecutorService()
DSubmissionPublisher.java247 final Executor executor; field in SubmissionPublisher
271 public SubmissionPublisher(Executor executor, int maxBufferCapacity, in SubmissionPublisher()
299 public SubmissionPublisher(Executor executor, int maxBufferCapacity) { in SubmissionPublisher()
1014 Executor executor; // null on error field in SubmissionPublisher.BufferedSubscription
1037 Executor executor, in BufferedSubscription()
/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/ojluni/src/main/java/java/nio/channels/
DAsynchronousChannelGroup.java228 public static AsynchronousChannelGroup withCachedThreadPool(ExecutorService executor, in withCachedThreadPool()
269 public static AsynchronousChannelGroup withThreadPool(ExecutorService executor) in withThreadPool()
DAsynchronousFileChannel.java243 ExecutorService executor, in open()
/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/security/KeyAgreement/
DMultiThreadTest.java114 ExecutorService executor = null; in runTest() local
/libcore/luni/src/test/java/libcore/java/util/zip/
DDeflaterOutputStreamTest.java76 ExecutorService executor = Executors.newSingleThreadExecutor(); in createInflaterStream() local
/libcore/luni/src/test/java/libcore/java/lang/ref/
DReferenceQueueTest.java146 final ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(1); in runLater() local
/libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/io/
DWriterTesterTest.java109 private ExecutorService executor; field in WriterTesterTest.PipedWriterCharSinkTester
DOutputStreamTesterTest.java116 private ExecutorService executor; field in OutputStreamTesterTest.PipedOutputStreamSinkTester
/libcore/luni/src/test/java/libcore/java/nio/channels/
DServerSocketChannelTest.java168 ExecutorService executor = Executors.newSingleThreadExecutor(); in bind_loopback() local
/libcore/jsr166-tests/src/test/java/jsr166/
DLinkedBlockingQueueTest.java731 final ExecutorService executor = Executors.newFixedThreadPool(2); in testOfferInExecutor() local
755 final ExecutorService executor = Executors.newFixedThreadPool(2); in testPollInExecutor() local
DArrayBlockingQueueTest.java797 final ExecutorService executor = Executors.newFixedThreadPool(2); in testOfferInExecutor() local
822 final ExecutorService executor = Executors.newFixedThreadPool(2); in testPollInExecutor() local

12