Home
last modified time | relevance | path

Searched refs:Executors (Results 1 – 25 of 33) sorted by relevance

12

/libcore/jsr166-tests/src/test/java/jsr166/
DExecutorsTest.java23 ExecutorService e = Executors.newCachedThreadPool(); in testNewCachedThreadPool1()
34 ExecutorService e = Executors.newCachedThreadPool(new SimpleThreadFactory()); in testNewCachedThreadPool2()
46 ExecutorService e = Executors.newCachedThreadPool(null); in testNewCachedThreadPool3()
55 ExecutorService e = Executors.newSingleThreadExecutor(); in testNewSingleThreadExecutor1()
66 ExecutorService e = Executors.newSingleThreadExecutor(new SimpleThreadFactory()); in testNewSingleThreadExecutor2()
78 ExecutorService e = Executors.newSingleThreadExecutor(null); in testNewSingleThreadExecutor3()
87 ExecutorService e = Executors.newSingleThreadExecutor(); in testCastNewSingleThreadExecutor()
101 ExecutorService e = Executors.newFixedThreadPool(2); in testNewFixedThreadPool1()
112 ExecutorService e = Executors.newFixedThreadPool(2, new SimpleThreadFactory()); in testNewFixedThreadPool2()
124 ExecutorService e = Executors.newFixedThreadPool(2, null); in testNewFixedThreadPool3()
[all …]
DExecutorCompletionServiceTest.java17 import java.util.concurrent.Executors;
44 ExecutorService e = Executors.newCachedThreadPool(); in testConstructorNPE2()
54 ExecutorService e = Executors.newCachedThreadPool(); in testSubmitNPE()
70 ExecutorService e = Executors.newCachedThreadPool(); in testSubmitNPE2()
86 ExecutorService e = Executors.newCachedThreadPool(); in testTake()
102 ExecutorService e = Executors.newCachedThreadPool(); in testTake2()
118 ExecutorService e = Executors.newCachedThreadPool(); in testPoll1()
143 ExecutorService e = Executors.newCachedThreadPool(); in testPoll2()
DAbstractExecutorServiceTest.java94 Future future = e.submit(Executors.callable(new PrivilegedAction() { in testSubmitPrivilegedAction()
115 Future future = e.submit(Executors.callable(new PrivilegedExceptionAction() { in testSubmitPrivilegedExceptionAction()
133 Future future = e.submit(Executors.callable(new PrivilegedExceptionAction() { in testSubmitFailedPrivilegedExceptionAction()
589 l.add(Executors.callable(possiblyInterruptedRunnable(2 * SHORT_DELAY_MS), TEST_STRING)); in testTimedInvokeAll6()
DSynchronousQueueTest.java20 import java.util.concurrent.Executors;
457 ExecutorService executor = Executors.newFixedThreadPool(2);
485 ExecutorService executor = Executors.newFixedThreadPool(2);
DForkJoinPoolTest.java13 import java.util.concurrent.Executors;
481 final Callable callable = Executors.callable(new PrivilegedAction() { in testSubmitPrivilegedAction()
502 Executors.callable(new PrivilegedExceptionAction() { in testSubmitPrivilegedExceptionAction()
523 Executors.callable(new PrivilegedExceptionAction() { in testSubmitFailedPrivilegedExceptionAction()
DLinkedBlockingQueueTest.java21 import java.util.concurrent.Executors;
688 ExecutorService executor = Executors.newFixedThreadPool(2); in testOfferInExecutor()
713 ExecutorService executor = Executors.newFixedThreadPool(2); in testPollInExecutor()
DArrayBlockingQueueTest.java21 import java.util.concurrent.Executors;
754 ExecutorService executor = Executors.newFixedThreadPool(2); in testOfferInExecutor()
780 ExecutorService executor = Executors.newFixedThreadPool(2); in testPollInExecutor()
DPriorityBlockingQueueTest.java22 import java.util.concurrent.Executors;
602 ExecutorService executor = Executors.newFixedThreadPool(2); in testPollInExecutor()
DLinkedTransferQueueTest.java20 import java.util.concurrent.Executors;
569 ExecutorService executor = Executors.newFixedThreadPool(2); in testOfferInExecutor()
593 ExecutorService executor = Executors.newFixedThreadPool(2); in testPollInExecutor()
DDelayQueueTest.java20 import java.util.concurrent.Executors;
641 ExecutorService executor = Executors.newFixedThreadPool(2); in testPollInExecutor()
/libcore/luni/src/test/java/sun/misc/
DUnsafeTest.java23 import java.util.concurrent.Executors;
40 Callable<Object> callable = Executors.callable(new Runnable() { in test_getUnsafeForbiddenWithSystemCaller()
/libcore/support/src/test/java/tests/support/
DSupport_Exec.java32 import java.util.concurrent.Executors;
85 ExecutorService executorService = Executors.newFixedThreadPool(2); in execAndGetOutput()
125 ExecutorService executorService = Executors.newFixedThreadPool(2); in execAndCheckOutput()
/libcore/luni/src/test/java/tests/security/
DSecureRandomTest.java24 import java.util.concurrent.Executors;
79 ExecutorService executor = Executors.newFixedThreadPool(threads); in testSecureRandomThreadSafety()
/libcore/support/src/test/java/libcore/javax/net/ssl/
DTestSSLSocketPair.java22 import java.util.concurrent.Executors;
79 ExecutorService executor = Executors.newFixedThreadPool(2); in connect()
/libcore/luni/src/test/java/libcore/javax/net/ssl/
DSSLSocketTest.java40 import java.util.concurrent.Executors;
319 ExecutorService executor = Executors.newSingleThreadExecutor(); in test_SSLSocket_startHandshake()
372 final ExecutorService executor = Executors.newSingleThreadExecutor(); in test_SSLSocket_confirmSessionReuse()
412 ExecutorService executor = Executors.newSingleThreadExecutor(); in test_SSLSocket_startHandshake_noKeyStore()
442 ExecutorService executor = Executors.newSingleThreadExecutor(); in test_SSLSocket_startHandshake_noClientCertificate()
462 ExecutorService executor = Executors.newSingleThreadExecutor(); in test_SSLSocket_HandshakeCompletedListener()
584 ExecutorService executor = Executors.newSingleThreadExecutor(); in test_SSLSocket_HandshakeCompletedListener_RuntimeException()
650 ExecutorService executor = Executors.newSingleThreadExecutor(); in test_SSLSocket_setUseClientMode()
704 ExecutorService executor = Executors.newSingleThreadExecutor(); in test_SSLSocket_untrustedServer()
734 ExecutorService executor = Executors.newSingleThreadExecutor(); in test_SSLSocket_clientAuth()
[all …]
/libcore/luni/src/test/java/libcore/java/util/zip/
DDeflaterOutputStreamTest.java31 import java.util.concurrent.Executors;
72 ExecutorService executor = Executors.newSingleThreadExecutor(); in createInflaterStream()
/libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/io/
DOutputStreamTesterTest.java42 import java.util.concurrent.Executors;
123 executor = Executors.newSingleThreadExecutor(); in create()
DWriterTesterTest.java41 import java.util.concurrent.Executors;
116 executor = Executors.newSingleThreadExecutor(); in create()
/libcore/luni/src/test/java/libcore/java/security/
DMessageDigestTest.java30 import java.util.concurrent.Executors;
250 ExecutorService es = Executors.newFixedThreadPool(THREAD_COUNT); in testMessageDigest_MultipleThreads_Misuse()
/libcore/luni/src/test/java/libcore/java/util/concurrent/
DCopyOnWriteArrayListTest.java28 import java.util.concurrent.Executors;
179 ExecutorService executor = Executors.newSingleThreadExecutor(); in testAddAllIsAtomic()
/libcore/luni/src/main/java/java/util/concurrent/
DExecutors.java43 public class Executors { class
658 private Executors() {}
DFutureTask.java123 this.callable = Executors.callable(runnable, result); in FutureTask()
DThreadPoolExecutor.java1166 Executors.defaultThreadFactory(), defaultHandler); in ThreadPoolExecutor()
1236 Executors.defaultThreadFactory(), handler); in ThreadPoolExecutor()
/libcore/luni/src/test/java/libcore/java/net/
DSocketTest.java35 import java.util.concurrent.Executors;
362 executor = Executors.newCachedThreadPool(); in MockServer()
/libcore/support/src/test/java/tests/http/
DMockWebServer.java44 import java.util.concurrent.Executors;
177 executor = Executors.newCachedThreadPool(); in play()

12