| /libcore/ojluni/src/main/java/sun/nio/ch/ |
| D | ThreadPool.java | 43 private final ExecutorService executor; field in ThreadPool
52 private ThreadPool(ExecutorService executor, in ThreadPool() argument
56 this.executor = executor; in ThreadPool()
61 ExecutorService executor() { in executor() method in ThreadPool
62 return executor; in executor()
121 ExecutorService executor = Executors.newCachedThreadPool(threadFactory); in createDefault() local
122 return new ThreadPool(executor, false, initialSize); in createDefault()
129 ExecutorService executor = Executors.newFixedThreadPool(nThreads, factory); in create() local
130 return new ThreadPool(executor, true, nThreads); in create()
134 public static ThreadPool wrap(ExecutorService executor, int initialSize) { in wrap() argument
[all …]
|
| D | SimpleAsynchronousFileChannelImpl.java | 47 ThreadPool.createDefault().executor();
60 ExecutorService executor) in SimpleAsynchronousFileChannelImpl() argument
62 super(fdObj, reading, writing, executor); in SimpleAsynchronousFileChannelImpl()
71 ExecutorService executor = (pool == null) ? in open() local
72 DefaultExecutorHolder.defaultExecutor : pool.executor(); in open()
73 return new SimpleAsynchronousFileChannelImpl(fdo, reading, writing, executor); in open()
190 Invoker.invokeIndirectly(handler, attachment, null, exc, executor); in implLock()
231 executor.execute(task); in implLock()
305 Invoker.invokeIndirectly(handler, attachment, 0, exc, executor); in implRead()
339 executor.execute(task); in implRead()
[all …]
|
| D | AsynchronousChannelGroupImpl.java | 91 final ExecutorService executor() { in executor() method in AsynchronousChannelGroupImpl
92 return pool.executor(); in executor()
140 pool.executor().execute(task);
161 pool.executor().execute(bindToGroup(task));
188 pool.executor().execute(bindToGroup(task));
219 return pool.executor().isTerminated();
251 pool.executor().shutdown();
309 return pool.executor().awaitTermination(timeout, unit);
|
| D | AsynchronousFileChannelImpl.java | 55 protected final ExecutorService executor; field in AsynchronousFileChannelImpl
60 ExecutorService executor) in AsynchronousFileChannelImpl() argument
65 this.executor = executor; in AsynchronousFileChannelImpl()
68 final ExecutorService executor() { in executor() method in AsynchronousFileChannelImpl
69 return executor; in executor()
|
| D | LinuxAsynchronousChannelProvider.java | 61 …public AsynchronousChannelGroup openAsynchronousChannelGroup(ExecutorService executor, int initial… in openAsynchronousChannelGroup() argument
64 return new EPollPort(this, ThreadPool.wrap(executor, initialSize)).start(); in openAsynchronousChannelGroup()
|
| /libcore/ojluni/src/main/java/java/util/concurrent/ |
| D | ExecutorCompletionService.java | 104 private final Executor executor; field in ExecutorCompletionService
145 public ExecutorCompletionService(Executor executor) { in ExecutorCompletionService() argument
146 if (executor == null) in ExecutorCompletionService()
148 this.executor = executor; in ExecutorCompletionService()
149 this.aes = (executor instanceof AbstractExecutorService) ? in ExecutorCompletionService()
150 (AbstractExecutorService) executor : null; in ExecutorCompletionService()
167 public ExecutorCompletionService(Executor executor, in ExecutorCompletionService() argument
169 if (executor == null || completionQueue == null) in ExecutorCompletionService()
171 this.executor = executor; in ExecutorCompletionService()
172 this.aes = (executor instanceof AbstractExecutorService) ? in ExecutorCompletionService()
[all …]
|
| D | CompletionStage.java | 205 Executor executor); in thenApplyAsync() argument
250 Executor executor); in thenAcceptAsync() argument
291 Executor executor); in thenRunAsync() argument
352 Executor executor); in thenCombineAsync() argument
410 Executor executor); in thenAcceptBothAsync() argument
458 Executor executor); in runAfterBothAsync() argument
515 Executor executor); in applyToEitherAsync() argument
570 Executor executor); in acceptEitherAsync() argument
621 Executor executor); in runAfterEitherAsync() argument
699 Executor executor); in thenComposeAsync() argument
[all …]
|
| D | CompletableFuture.java | 527 Executor executor; // executor to use (null if none) field in CompletableFuture.UniCompletion
531 UniCompletion(Executor executor, CompletableFuture<V> dep, in UniCompletion() argument
533 this.executor = executor; this.dep = dep; this.src = src; in UniCompletion()
543 Executor e = executor; in claim()
547 executor = null; // disable in claim()
598 UniApply(Executor executor, CompletableFuture<V> dep, in UniApply() argument
601 super(executor, dep, src); this.fn = fn; in UniApply()
671 UniAccept(Executor executor, CompletableFuture<Void> dep, in UniAccept() argument
673 super(executor, dep, src); this.fn = fn; in UniAccept()
745 UniRun(Executor executor, CompletableFuture<Void> dep, in UniRun() argument
[all …]
|
| D | Executors.java | 323 public static ExecutorService unconfigurableExecutorService(ExecutorService executor) { in unconfigurableExecutorService() argument
324 if (executor == null) in unconfigurableExecutorService()
326 return new DelegatedExecutorService(executor); in unconfigurableExecutorService()
339 …cheduledExecutorService unconfigurableScheduledExecutorService(ScheduledExecutorService executor) { in unconfigurableScheduledExecutorService() argument
340 if (executor == null) in unconfigurableScheduledExecutorService()
342 return new DelegatedScheduledExecutorService(executor); in unconfigurableScheduledExecutorService()
675 DelegatedExecutorService(ExecutorService executor) { e = executor; }
748 FinalizableDelegatedExecutorService(ExecutorService executor) {
749 super(executor);
765 DelegatedScheduledExecutorService(ScheduledExecutorService executor) {
[all …]
|
| D | SubmissionPublisher.java | 250 final Executor executor; field in SubmissionPublisher
274 public SubmissionPublisher(Executor executor, int maxBufferCapacity, in SubmissionPublisher() argument
276 if (executor == null) in SubmissionPublisher()
281 this.executor = executor; in SubmissionPublisher()
303 public SubmissionPublisher(Executor executor, int maxBufferCapacity) { in SubmissionPublisher() argument
304 this(executor, maxBufferCapacity, null); in SubmissionPublisher()
349 new BufferedSubscription<T>(subscriber, executor, onNextHandler, in subscribe()
754 return executor; in getExecutor()
1061 Executor executor; // null on error field in SubmissionPublisher.BufferedSubscription
1084 Executor executor, in BufferedSubscription() argument
[all …]
|
| D | RejectedExecutionHandler.java | 61 void rejectedExecution(Runnable r, ThreadPoolExecutor executor); in rejectedExecution() argument
|
| /libcore/luni/src/test/java/libcore/java/util/concurrent/ |
| D | CompletionStageTest.java | 43 private Executor executor = null; field in CompletionStageTest.BaseStage
52 BaseStage(Executor executor) { in BaseStage() argument
53 this.executor = executor; in BaseStage()
57 return executor != null; in hasExecutor()
61 executor.execute(() -> { in execute()
109 Executor executor) { in thenApplyAsync() argument
122 Executor executor) { in thenAcceptAsync() argument
135 Executor executor) { in thenRunAsync() argument
151 Executor executor) { in thenCombineAsync() argument
167 Executor executor) { in thenAcceptBothAsync() argument
[all …]
|
| /libcore/ojluni/src/main/java/java/nio/channels/ |
| D | AsynchronousChannelGroup.java | 233 public static AsynchronousChannelGroup withCachedThreadPool(ExecutorService executor, in withCachedThreadPool() argument
238 .openAsynchronousChannelGroup(executor, initialSize); in withCachedThreadPool()
274 public static AsynchronousChannelGroup withThreadPool(ExecutorService executor) in withThreadPool() argument
278 .openAsynchronousChannelGroup(executor, 0); in withThreadPool()
|
| /libcore/ojluni/src/test/java/security/KeyAgreement/ |
| D | MultiThreadTest.java | 114 ExecutorService executor = null; in runTest() local
116 executor = Executors.newCachedThreadPool(new ThreadFactory() { in runTest()
127 executor.execute(new Runnable() { in runTest()
144 if (executor != null) { in runTest()
145 executor.shutdown(); in runTest()
|
| /libcore/ojluni/annotations/mmodule/java/util/concurrent/ |
| D | CompletableFuture.annotated.java | 48 …(java.util.function.Supplier<U> supplier, java.util.concurrent.Executor executor) { throw new Runt… in supplyAsync() argument
52 …id> runAsync(java.lang.Runnable runnable, java.util.concurrent.Executor executor) { throw new Runt… in runAsync() argument
74 …ction.Function<? super T,? extends U> fn, java.util.concurrent.Executor executor) { throw new Runt… in thenApplyAsync() argument
80 …util.function.Consumer<? super T> action, java.util.concurrent.Executor executor) { throw new Runt… in thenAcceptAsync() argument
86 …> thenRunAsync(java.lang.Runnable action, java.util.concurrent.Executor executor) { throw new Runt… in thenRunAsync() argument
92 …tion<? super T,? super U,? extends V> fn, java.util.concurrent.Executor executor) { throw new Runt… in thenCombineAsync() argument
98 …n.BiConsumer<? super T,? super U> action, java.util.concurrent.Executor executor) { throw new Runt… in thenAcceptBothAsync() argument
104 …tage<?> other, java.lang.Runnable action, java.util.concurrent.Executor executor) { throw new Runt… in runAfterBothAsync() argument
110 …a.util.function.Function<? super T,U> fn, java.util.concurrent.Executor executor) { throw new Runt… in applyToEitherAsync() argument
116 …util.function.Consumer<? super T> action, java.util.concurrent.Executor executor) { throw new Runt… in acceptEitherAsync() argument
[all …]
|
| /libcore/support/src/test/java/libcore/javax/net/ssl/ |
| D | TestSSLSocketPair.java | 78 ExecutorService executor = Executors.newFixedThreadPool(2); in connect() local
79 Future s = executor.submit(new Callable<Void>() { in connect()
88 Future c = executor.submit(new Callable<Void>() { in connect()
97 executor.shutdown(); in connect()
|
| /libcore/luni/src/test/java/tests/security/ |
| D | SecureRandomTest.java | 79 ExecutorService executor = Executors.newFixedThreadPool(threads); in testSecureRandomThreadSafety() local
80 ExecutorCompletionService ecs = new ExecutorCompletionService(executor); in testSecureRandomThreadSafety()
91 executor.shutdown(); in testSecureRandomThreadSafety()
|
| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/io/ |
| D | OutputStreamTesterTest.java | 116 private ExecutorService executor; field in OutputStreamTesterTest.PipedOutputStreamSinkTester
123 executor = Executors.newSingleThreadExecutor(); in create()
124 future = executor.submit(new Callable<byte[]>() { in create()
141 executor.shutdown(); in getBytes()
|
| D | WriterTesterTest.java | 109 private ExecutorService executor; field in WriterTesterTest.PipedWriterCharSinkTester
116 executor = Executors.newSingleThreadExecutor(); in create()
117 future = executor.submit(new Callable<char[]>() { in create()
135 executor.shutdown(); in getChars()
|
| /libcore/ojluni/src/test/java/lang/constant/ |
| D | DynamicConstantDescTest.java | 71 final ExecutorService executor = Executors.newFixedThreadPool(tasks.size()); in main() local
77 results[i++] = executor.submit(task); in main()
84 executor.shutdownNow(); in main()
|
| /libcore/luni/src/test/java/libcore/java/util/zip/ |
| D | DeflaterOutputStreamTest.java | 76 ExecutorService executor = Executors.newSingleThreadExecutor(); in createInflaterStream() local
80 executor.submit(new Callable<Void>() { in createInflaterStream()
97 executor.shutdown(); in createInflaterStream()
|
| /libcore/luni/src/test/java/libcore/java/lang/ref/ |
| D | ReferenceQueueTest.java | 146 final ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(1); in runLater() local
147 executor.schedule(runnable, delayMillis, TimeUnit.MILLISECONDS); in runLater()
148 executor.shutdown(); in runLater()
|
| /libcore/jsr166-tests/src/test/java/jsr166/ |
| 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() {
|
| /libcore/ojluni/src/test/java/util/concurrent/tck/ |
| D | SynchronousQueueTest.java | 501 final ExecutorService executor = Executors.newFixedThreadPool(2);
502 try (PoolCleaner cleaner = cleaner(executor)) {
504 executor.execute(new CheckedRunnable() {
512 executor.execute(new CheckedRunnable() {
528 final ExecutorService executor = Executors.newFixedThreadPool(2);
529 try (PoolCleaner cleaner = cleaner(executor)) {
530 executor.execute(new CheckedRunnable() {
538 executor.execute(new CheckedRunnable() {
|
| /libcore/ojluni/annotations/hiddenapi/java/util/concurrent/ |
| D | Executors.java | 102 java.util.concurrent.ExecutorService executor) { in unconfigurableExecutorService() argument
108 java.util.concurrent.ScheduledExecutorService executor) { in unconfigurableScheduledExecutorService() argument
189 DelegatedExecutorService(java.util.concurrent.ExecutorService executor) { in DelegatedExecutorService() argument
271 DelegatedScheduledExecutorService(java.util.concurrent.ScheduledExecutorService executor) { in DelegatedScheduledExecutorService() argument
315 FinalizableDelegatedExecutorService(java.util.concurrent.ExecutorService executor) { in FinalizableDelegatedExecutorService() argument
|