| /libcore/luni/src/main/java/java/util/concurrent/ |
| D | ExecutorCompletionService.java | 78 private final Executor executor; field in ExecutorCompletionService
119 public ExecutorCompletionService(Executor executor) { in ExecutorCompletionService() argument
120 if (executor == null) in ExecutorCompletionService()
122 this.executor = executor; in ExecutorCompletionService()
123 this.aes = (executor instanceof AbstractExecutorService) ? in ExecutorCompletionService()
124 (AbstractExecutorService) executor : null; in ExecutorCompletionService()
141 public ExecutorCompletionService(Executor executor, in ExecutorCompletionService() argument
143 if (executor == null || completionQueue == null) in ExecutorCompletionService()
145 this.executor = executor; in ExecutorCompletionService()
146 this.aes = (executor instanceof AbstractExecutorService) ? in ExecutorCompletionService()
[all …]
|
| D | CompletionStage.java | 176 Executor executor); in thenApplyAsync() argument
221 Executor executor); in thenAcceptAsync() argument
262 Executor executor); in thenRunAsync() argument
323 Executor executor); in thenCombineAsync() argument
381 Executor executor); in thenAcceptBothAsync() argument
429 Executor executor); in runAfterBothAsync() argument
486 Executor executor); in applyToEitherAsync() argument
541 Executor executor); in acceptEitherAsync() argument
592 Executor executor); in runAfterEitherAsync() argument
670 Executor executor); in thenComposeAsync() argument
[all …]
|
| D | Executors.java | 292 public static ExecutorService unconfigurableExecutorService(ExecutorService executor) { in unconfigurableExecutorService() argument
293 if (executor == null) in unconfigurableExecutorService()
295 return new DelegatedExecutorService(executor); in unconfigurableExecutorService()
308 …cheduledExecutorService unconfigurableScheduledExecutorService(ScheduledExecutorService executor) { in unconfigurableScheduledExecutorService() argument
309 if (executor == null) in unconfigurableScheduledExecutorService()
311 return new DelegatedScheduledExecutorService(executor); in unconfigurableScheduledExecutorService()
590 DelegatedExecutorService(ExecutorService executor) { e = executor; }
631 FinalizableDelegatedExecutorService(ExecutorService executor) {
632 super(executor);
647 DelegatedScheduledExecutorService(ScheduledExecutorService executor) {
[all …]
|
| D | CompletableFuture.java | 487 Executor executor; // executor to use (null if none) field in CompletableFuture.UniCompletion
491 UniCompletion(Executor executor, CompletableFuture<V> dep, in UniCompletion() argument
493 this.executor = executor; this.dep = dep; this.src = src; in UniCompletion()
503 Executor e = executor; in claim()
507 executor = null; // disable in claim()
548 UniApply(Executor executor, CompletableFuture<V> dep, in UniApply() argument
551 super(executor, dep, src); this.fn = fn; in UniApply()
604 UniAccept(Executor executor, CompletableFuture<Void> dep, in UniAccept() argument
606 super(executor, dep, src); this.fn = fn; in UniAccept()
659 UniRun(Executor executor, CompletableFuture<Void> dep, in UniRun() argument
[all …]
|
| D | RejectedExecutionHandler.java | 32 void rejectedExecution(Runnable r, ThreadPoolExecutor executor); in rejectedExecution() argument
|
| /libcore/ojluni/src/main/java/sun/nio/ch/ |
| D | ThreadPool.java | 51 private final ExecutorService executor; field in ThreadPool
60 private ThreadPool(ExecutorService executor, in ThreadPool() argument
64 this.executor = executor; in ThreadPool()
69 ExecutorService executor() { in executor() method in ThreadPool
70 return executor; in executor()
105 ExecutorService executor = in createDefault() local
110 return new ThreadPool(executor, false, initialSize); in createDefault()
117 ExecutorService executor = Executors.newFixedThreadPool(nThreads, factory); in create() local
118 return new ThreadPool(executor, true, nThreads); in create()
122 public static ThreadPool wrap(ExecutorService executor, int initialSize) { in wrap() argument
[all …]
|
| /libcore/luni/src/test/java/libcore/javax/net/ssl/ |
| D | SSLSocketTest.java | 349 ExecutorService executor = Executors.newSingleThreadExecutor(); in test_SSLSocket_startHandshake() local
350 Future<Void> future = executor.submit(new Callable<Void>() { in test_SSLSocket_startHandshake()
371 executor.shutdown(); in test_SSLSocket_startHandshake()
403 final ExecutorService executor = Executors.newSingleThreadExecutor(); in test_SSLSocket_confirmSessionReuse() local
408 final Future<byte[]> future1 = executor.submit(new SSLServerSessionIdCallable(server1)); in test_SSLSocket_confirmSessionReuse()
421 final Future<byte[]> future2 = executor.submit(new SSLServerSessionIdCallable(server2)); in test_SSLSocket_confirmSessionReuse()
433 executor.shutdown(); in test_SSLSocket_confirmSessionReuse()
444 ExecutorService executor = Executors.newSingleThreadExecutor(); in test_SSLSocket_NoEnabledCipherSuites_Failure() local
445 Future<Void> future = executor.submit(new Callable<Void>() { in test_SSLSocket_NoEnabledCipherSuites_Failure()
456 executor.shutdown(); in test_SSLSocket_NoEnabledCipherSuites_Failure()
[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 | 72 ExecutorService executor = Executors.newSingleThreadExecutor(); in createInflaterStream() local
76 executor.submit(new Callable<Void>() { in createInflaterStream()
93 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()
|
| D | ExecutorsTest.java | 290 for (final ExecutorService executor : executors) { in testTimedCallable()
293 Future future = executor.submit(sleeper); in testTimedCallable()
299 for (ExecutorService executor : executors) in testTimedCallable()
300 joinPool(executor); in testTimedCallable()
|
| D | LinkedTransferQueueTest.java | 603 final ExecutorService executor = Executors.newFixedThreadPool(2); in testOfferInExecutor() local
604 try (PoolCleaner cleaner = cleaner(executor)) { in testOfferInExecutor()
606 executor.execute(new CheckedRunnable() { in testOfferInExecutor()
614 executor.execute(new CheckedRunnable() { in testOfferInExecutor()
629 final ExecutorService executor = Executors.newFixedThreadPool(2); in testPollInExecutor() local
630 try (PoolCleaner cleaner = cleaner(executor)) { in testPollInExecutor()
632 executor.execute(new CheckedRunnable() { in testPollInExecutor()
642 executor.execute(new CheckedRunnable() { in testPollInExecutor()
|
| D | PriorityBlockingQueueTest.java | 632 final ExecutorService executor = Executors.newFixedThreadPool(2); in testPollInExecutor() local
633 try (PoolCleaner cleaner = cleaner(executor)) { in testPollInExecutor()
634 executor.execute(new CheckedRunnable() { in testPollInExecutor()
642 executor.execute(new CheckedRunnable() { in testPollInExecutor()
|
| D | DelayQueueTest.java | 675 final ExecutorService executor = Executors.newFixedThreadPool(2); in testPollInExecutor() local
676 try (PoolCleaner cleaner = cleaner(executor)) { in testPollInExecutor()
677 executor.execute(new CheckedRunnable() { in testPollInExecutor()
685 executor.execute(new CheckedRunnable() { in testPollInExecutor()
|
| D | LinkedBlockingDequeTest.java | 1685 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() {
|
| /libcore/tzdata/update_test_app/src/libcore/tzdata/update_test_app/installupdatetestapp/ |
| D | MainActivity.java | 54 private ExecutorService executor; field in MainActivity
69 executor = Executors.newFixedThreadPool(1); in onCreate()
114 }.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()
|
| /libcore/luni/src/test/java/libcore/java/net/ |
| D | SocketTest.java | 451 private ExecutorService executor; field in SocketTest.MockServer
456 executor = Executors.newCachedThreadPool(); in MockServer()
464 return executor.submit(new Callable<byte[]>() { in enqueue()
484 executor.shutdown(); in shutdown()
|
| /libcore/luni/src/test/java/libcore/java/util/concurrent/ |
| D | CopyOnWriteArrayListTest.java | 180 ExecutorService executor = Executors.newSingleThreadExecutor(); in testAddAllIsAtomic() local
181 Future<?> future = executor.submit(new Runnable() { in testAddAllIsAtomic()
190 executor.shutdown(); in testAddAllIsAtomic()
|