| /libcore/ojluni/src/main/java/java/util/concurrent/ |
| D | ExecutorCompletionService.java | 107 private final Executor executor; field in ExecutorCompletionService
148 public ExecutorCompletionService(Executor executor) { in ExecutorCompletionService() argument
149 if (executor == null) in ExecutorCompletionService()
151 this.executor = executor; in ExecutorCompletionService()
152 this.aes = (executor instanceof AbstractExecutorService) ? in ExecutorCompletionService()
153 (AbstractExecutorService) executor : null; in ExecutorCompletionService()
170 public ExecutorCompletionService(Executor executor, in ExecutorCompletionService() argument
172 if (executor == null || completionQueue == null) in ExecutorCompletionService()
174 this.executor = executor; in ExecutorCompletionService()
175 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 | Executors.java | 321 public static ExecutorService unconfigurableExecutorService(ExecutorService executor) { in unconfigurableExecutorService() argument
322 if (executor == null) in unconfigurableExecutorService()
324 return new DelegatedExecutorService(executor); in unconfigurableExecutorService()
337 …cheduledExecutorService unconfigurableScheduledExecutorService(ScheduledExecutorService executor) { in unconfigurableScheduledExecutorService() argument
338 if (executor == null) in unconfigurableScheduledExecutorService()
340 return new DelegatedScheduledExecutorService(executor); in unconfigurableScheduledExecutorService()
619 DelegatedExecutorService(ExecutorService executor) { e = executor; }
660 FinalizableDelegatedExecutorService(ExecutorService executor) {
661 super(executor);
676 DelegatedScheduledExecutorService(ScheduledExecutorService executor) {
[all …]
|
| D | CompletableFuture.java | 516 Executor executor; // executor to use (null if none) field in CompletableFuture.UniCompletion
520 UniCompletion(Executor executor, CompletableFuture<V> dep, in UniCompletion() argument
522 this.executor = executor; this.dep = dep; this.src = src; in UniCompletion()
532 Executor e = executor; in claim()
536 executor = null; // disable in claim()
577 UniApply(Executor executor, CompletableFuture<V> dep, in UniApply() argument
580 super(executor, dep, src); this.fn = fn; in UniApply()
633 UniAccept(Executor executor, CompletableFuture<Void> dep, in UniAccept() argument
635 super(executor, dep, src); this.fn = fn; in UniAccept()
688 UniRun(Executor executor, CompletableFuture<Void> dep, in UniRun() argument
[all …]
|
| D | RejectedExecutionHandler.java | 61 void rejectedExecution(Runnable r, ThreadPoolExecutor executor); in rejectedExecution() argument
|
| /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()
113 ExecutorService executor = Executors.newCachedThreadPool(threadFactory); in createDefault() local
114 return new ThreadPool(executor, false, initialSize); in createDefault()
121 ExecutorService executor = Executors.newFixedThreadPool(nThreads, factory); in create() local
122 return new ThreadPool(executor, true, nThreads); in create()
126 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/nio/channels/ |
| D | AsynchronousChannelGroup.java | 228 public static AsynchronousChannelGroup withCachedThreadPool(ExecutorService executor, in withCachedThreadPool() argument
233 .openAsynchronousChannelGroup(executor, initialSize); in withCachedThreadPool()
269 public static AsynchronousChannelGroup withThreadPool(ExecutorService executor) in withThreadPool() argument
273 .openAsynchronousChannelGroup(executor, 0); in withThreadPool()
|
| D | AsynchronousFileChannel.java | 243 ExecutorService executor, in open() argument
248 return provider.newAsynchronousFileChannel(file, options, executor, attrs); in open()
|
| /libcore/luni/src/test/java/libcore/javax/net/ssl/ |
| D | SSLSocketTest.java | 371 ExecutorService executor = Executors.newSingleThreadExecutor(); in test_SSLSocket_noncontiguousProtocols_useLower() local
372 Future<Void> future = executor.submit(new Callable<Void>() { in test_SSLSocket_noncontiguousProtocols_useLower()
378 executor.shutdown(); in test_SSLSocket_noncontiguousProtocols_useLower()
402 ExecutorService executor = Executors.newSingleThreadExecutor(); in test_SSLSocket_noncontiguousProtocols_canNegotiate() local
403 Future<Void> future = executor.submit(new Callable<Void>() { in test_SSLSocket_noncontiguousProtocols_canNegotiate()
409 executor.shutdown(); in test_SSLSocket_noncontiguousProtocols_canNegotiate()
440 ExecutorService executor = Executors.newSingleThreadExecutor(); in test_SSLSocket_startHandshake() local
441 Future<Void> future = executor.submit(new Callable<Void>() { in test_SSLSocket_startHandshake()
462 executor.shutdown(); in test_SSLSocket_startHandshake()
494 final ExecutorService executor = Executors.newSingleThreadExecutor(); in test_SSLSocket_confirmSessionReuse() local
[all …]
|
| /libcore/support/src/test/java/libcore/javax/net/ssl/ |
| D | TestSSLSocketPair.java | 79 ExecutorService executor = Executors.newFixedThreadPool(2); in connect() local
80 Future s = executor.submit(new Callable<Void>() { in connect()
89 Future c = executor.submit(new Callable<Void>() { in connect()
98 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/luni/src/test/java/libcore/java/lang/ref/ |
| D | ReferenceQueueTest.java | 124 ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(1); in runLater() local
125 executor.schedule(runnable, delayMillis, TimeUnit.MILLISECONDS); in runLater()
126 executor.shutdown(); in runLater()
|
| /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/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() {
|
| D | LinkedBlockingQueueTest.java | 731 final ExecutorService executor = Executors.newFixedThreadPool(2); in testOfferInExecutor() local
732 try (PoolCleaner cleaner = cleaner(executor)) { in testOfferInExecutor()
733 executor.execute(new CheckedRunnable() { in testOfferInExecutor()
741 executor.execute(new CheckedRunnable() { in testOfferInExecutor()
755 final ExecutorService executor = Executors.newFixedThreadPool(2); in testPollInExecutor() local
756 try (PoolCleaner cleaner = cleaner(executor)) { in testPollInExecutor()
757 executor.execute(new CheckedRunnable() { in testPollInExecutor()
765 executor.execute(new CheckedRunnable() { in testPollInExecutor()
|
| D | ArrayBlockingQueueTest.java | 797 final ExecutorService executor = Executors.newFixedThreadPool(2); in testOfferInExecutor() local
798 try (PoolCleaner cleaner = cleaner(executor)) { in testOfferInExecutor()
799 executor.execute(new CheckedRunnable() { in testOfferInExecutor()
807 executor.execute(new CheckedRunnable() { in testOfferInExecutor()
822 final ExecutorService executor = Executors.newFixedThreadPool(2); in testPollInExecutor() local
823 try (PoolCleaner cleaner = cleaner(executor)) { in testPollInExecutor()
824 executor.execute(new CheckedRunnable() { in testPollInExecutor()
832 executor.execute(new CheckedRunnable() { in testPollInExecutor()
|
| /libcore/luni/src/test/java/libcore/net/ |
| D | NetworkSecurityPolicyTest.java | 240 private final ExecutorService executor; field in NetworkSecurityPolicyTest.CapturingServerSocket
278 executor = Executors.newSingleThreadExecutor(); in CapturingServerSocket()
279 mFirstChunkReceivedFuture = executor.submit(callable); in CapturingServerSocket()
293 executor.shutdown(); in close()
|
| /libcore/tzdata/update_test_app/src/libcore/tzdata/update_test_app/installupdatetestapp/ |
| D | MainActivity.java | 56 private ExecutorService executor; field in MainActivity
71 executor = Executors.newFixedThreadPool(1); in onCreate()
122 }.executeOnExecutor(executor); in onClick()
|
| /libcore/support/src/test/java/tests/http/ |
| D | MockWebServer.java | 77 private ExecutorService executor; field in MockWebServer
177 executor = Executors.newCachedThreadPool(); in play()
182 executor.execute(namedRunnable("MockWebServer-accept-" + port, new Runnable() { in play()
208 executor.shutdown(); in play()
243 executor.execute(namedRunnable(name, new Runnable() { in serveConnection()
|