Home
last modified time | relevance | path

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

/libcore/ojluni/src/main/java/sun/nio/ch/
DThreadPool.java51 private final ExecutorService executor; field in ThreadPool
60 private ThreadPool(ExecutorService executor, in ThreadPool()
69 ExecutorService executor() { in executor() method in ThreadPool
105 ExecutorService executor = in createDefault() local
117 ExecutorService executor = Executors.newFixedThreadPool(nThreads, factory); in create() local
122 public static ThreadPool wrap(ExecutorService executor, int initialSize) { in wrap()
/libcore/luni/src/main/java/java/util/concurrent/
DCompletionStage.java176 Executor executor); in thenApplyAsync()
221 Executor executor); in thenAcceptAsync()
262 Executor executor); in thenRunAsync()
323 Executor executor); in thenCombineAsync()
381 Executor executor); in thenAcceptBothAsync()
429 Executor executor); in runAfterBothAsync()
486 Executor executor); in applyToEitherAsync()
541 Executor executor); in acceptEitherAsync()
592 Executor executor); in runAfterEitherAsync()
670 Executor executor); in thenComposeAsync()
[all …]
DExecutorCompletionService.java78 private final Executor executor; field in ExecutorCompletionService
119 public ExecutorCompletionService(Executor executor) { in ExecutorCompletionService()
141 public ExecutorCompletionService(Executor executor, in ExecutorCompletionService()
DRejectedExecutionHandler.java32 void rejectedExecution(Runnable r, ThreadPoolExecutor executor); in rejectedExecution()
DExecutors.java292 public static ExecutorService unconfigurableExecutorService(ExecutorService executor) { in unconfigurableExecutorService()
308 …cheduledExecutorService unconfigurableScheduledExecutorService(ScheduledExecutorService executor) { in unconfigurableScheduledExecutorService()
DCompletableFuture.java487 Executor executor; // executor to use (null if none) field in CompletableFuture.UniCompletion
491 UniCompletion(Executor executor, CompletableFuture<V> dep, in UniCompletion()
548 UniApply(Executor executor, CompletableFuture<V> dep, in UniApply()
604 UniAccept(Executor executor, CompletableFuture<Void> dep, in UniAccept()
659 UniRun(Executor executor, CompletableFuture<Void> dep, in UniRun()
707 UniWhenComplete(Executor executor, CompletableFuture<T> dep, in UniWhenComplete()
770 UniHandle(Executor executor, CompletableFuture<V> dep, in UniHandle()
923 UniCompose(Executor executor, CompletableFuture<V> dep, in UniCompose()
1013 BiCompletion(Executor executor, CompletableFuture<V> dep, in BiCompletion()
1066 BiApply(Executor executor, CompletableFuture<V> dep, in BiApply()
[all …]
/libcore/luni/src/test/java/libcore/javax/net/ssl/
DSSLSocketTest.java349 ExecutorService executor = Executors.newSingleThreadExecutor(); in test_SSLSocket_startHandshake() local
403 final ExecutorService executor = Executors.newSingleThreadExecutor(); in test_SSLSocket_confirmSessionReuse() local
444 ExecutorService executor = Executors.newSingleThreadExecutor(); in test_SSLSocket_NoEnabledCipherSuites_Failure() local
474 ExecutorService executor = Executors.newSingleThreadExecutor(); in test_SSLSocket_startHandshake_noKeyStore() local
504 ExecutorService executor = Executors.newSingleThreadExecutor(); in test_SSLSocket_startHandshake_noClientCertificate() local
524 ExecutorService executor = Executors.newSingleThreadExecutor(); in test_SSLSocket_HandshakeCompletedListener() local
647 ExecutorService executor = Executors.newSingleThreadExecutor(); in test_SSLSocket_HandshakeCompletedListener_RuntimeException() local
713 ExecutorService executor = Executors.newSingleThreadExecutor(); in test_SSLSocket_setUseClientMode() local
767 ExecutorService executor = Executors.newSingleThreadExecutor(); in test_SSLSocket_untrustedServer() local
797 ExecutorService executor = Executors.newSingleThreadExecutor(); in test_SSLSocket_clientAuth() local
[all …]
/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.java79 ExecutorService executor = Executors.newFixedThreadPool(2); in connect() local
/libcore/luni/src/test/java/libcore/java/util/zip/
DDeflaterOutputStreamTest.java72 ExecutorService executor = Executors.newSingleThreadExecutor(); in createInflaterStream() local
/libcore/luni/src/test/java/libcore/java/lang/ref/
DReferenceQueueTest.java124 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/tzdata/update_test_app/src/libcore/tzdata/update_test_app/installupdatetestapp/
DMainActivity.java54 private ExecutorService executor; field in MainActivity
/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
DLinkedTransferQueueTest.java603 final ExecutorService executor = Executors.newFixedThreadPool(2); in testOfferInExecutor() local
629 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
DPriorityBlockingQueueTest.java632 final ExecutorService executor = Executors.newFixedThreadPool(2); in testPollInExecutor() local
DDelayQueueTest.java675 final ExecutorService executor = Executors.newFixedThreadPool(2); in testPollInExecutor() local
DCompletableFutureTest.java3502 ThreadExecutor executor = new ThreadExecutor(); in testCompleteAsync3() local
3503 f.completeAsync(() -> v1, executor); in testCompleteAsync3() local
3516 ThreadExecutor executor = new ThreadExecutor(); in testCompleteAsync4() local
3603 public void testDelayedExecutor(Executor executor, Integer v) throws Exception { in testDelayedExecutor()
/libcore/support/src/test/java/tests/http/
DMockWebServer.java77 private ExecutorService executor; field in MockWebServer
/libcore/luni/src/test/java/libcore/java/util/concurrent/
DCopyOnWriteArrayListTest.java180 ExecutorService executor = Executors.newSingleThreadExecutor(); in testAddAllIsAtomic() local
/libcore/luni/src/test/java/libcore/java/net/
DSocketTest.java451 private ExecutorService executor; field in SocketTest.MockServer
/libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/util/jar/
DJarFileTest.java656 ExecutorService executor = Executors.newSingleThreadExecutor(); in checkSignedJar() local