Home
last modified time | relevance | path

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

12

/libcore/jsr166-tests/src/test/java/jsr166/
DExecutorsTest.java22 import java.util.concurrent.Executors;
46 final ExecutorService e = Executors.newCachedThreadPool(); in testNewCachedThreadPool1()
58 final ExecutorService e = Executors.newCachedThreadPool(new SimpleThreadFactory()); in testNewCachedThreadPool2()
71 ExecutorService e = Executors.newCachedThreadPool(null); in testNewCachedThreadPool3()
80 final ExecutorService e = Executors.newSingleThreadExecutor(); in testNewSingleThreadExecutor1()
92 final ExecutorService e = Executors.newSingleThreadExecutor(new SimpleThreadFactory()); in testNewSingleThreadExecutor2()
105 ExecutorService e = Executors.newSingleThreadExecutor(null); in testNewSingleThreadExecutor3()
114 final ExecutorService e = Executors.newSingleThreadExecutor(); in testCastNewSingleThreadExecutor()
127 final ExecutorService e = Executors.newFixedThreadPool(2); in testNewFixedThreadPool1()
139 final ExecutorService e = Executors.newFixedThreadPool(2, new SimpleThreadFactory()); in testNewFixedThreadPool2()
[all …]
DExecutorCompletionServiceTest.java16 import java.util.concurrent.Executors;
54 ExecutorService e = Executors.newCachedThreadPool(); in testConstructorNPE2()
64 final ExecutorService e = Executors.newCachedThreadPool(); in testSubmitNPE()
79 final ExecutorService e = Executors.newCachedThreadPool(); in testSubmitNPE2()
94 final ExecutorService e = Executors.newCachedThreadPool(); in testTake()
108 final ExecutorService e = Executors.newCachedThreadPool(); in testTake2()
122 final ExecutorService e = Executors.newCachedThreadPool(); in testPoll1()
145 final ExecutorService e = Executors.newCachedThreadPool(); in testPoll2()
DCollection8Test.java16 import java.util.concurrent.Executors;
82 final ExecutorService pool = Executors.newCachedThreadPool(); in testForEachConcurrentStressTest()
DLongAccumulatorTest.java9 import java.util.concurrent.Executors;
127 final ExecutorService pool = Executors.newCachedThreadPool(); in testAccumulateAndGetMT()
DDoubleAccumulatorTest.java9 import java.util.concurrent.Executors;
127 final ExecutorService pool = Executors.newCachedThreadPool(); in testAccumulateAndGetMT()
DDoubleAdderTest.java10 import java.util.concurrent.Executors;
139 final ExecutorService pool = Executors.newCachedThreadPool(); in testAddAndSumMT()
DLongAdderTest.java10 import java.util.concurrent.Executors;
162 final ExecutorService pool = Executors.newCachedThreadPool(); in testAddAndSumMT()
DAbstractExecutorServiceTest.java24 import java.util.concurrent.Executors;
118 Future future = e.submit(Executors.callable(new PrivilegedAction() { in testSubmitPrivilegedAction()
139 Future future = e.submit(Executors.callable(new PrivilegedExceptionAction() { in testSubmitPrivilegedExceptionAction()
157 Future future = e.submit(Executors.callable(new PrivilegedExceptionAction() { in testSubmitFailedPrivilegedExceptionAction()
587 tasks.add(Executors.callable(possiblyInterruptedRunnable(timeout),
DSynchronousQueueTest.java20 import java.util.concurrent.Executors;
481 final ExecutorService executor = Executors.newFixedThreadPool(2);
508 final ExecutorService executor = Executors.newFixedThreadPool(2);
DForkJoinPoolTest.java20 import java.util.concurrent.Executors;
485 final Callable callable = Executors.callable(new PrivilegedAction() { in testSubmitPrivilegedAction()
504 Executors.callable(new PrivilegedExceptionAction() { in testSubmitPrivilegedExceptionAction()
523 Executors.callable(new PrivilegedExceptionAction() { in testSubmitFailedPrivilegedExceptionAction()
DLinkedBlockingQueueTest.java21 import java.util.concurrent.Executors;
731 final ExecutorService executor = Executors.newFixedThreadPool(2); in testOfferInExecutor()
755 final 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/luni/src/test/java/libcore/javax/net/ssl/
DSSLSocketTest.java46 import java.util.concurrent.Executors;
349 ExecutorService executor = Executors.newSingleThreadExecutor(); in test_SSLSocket_startHandshake()
403 final ExecutorService executor = Executors.newSingleThreadExecutor(); in test_SSLSocket_confirmSessionReuse()
444 ExecutorService executor = Executors.newSingleThreadExecutor(); in test_SSLSocket_NoEnabledCipherSuites_Failure()
474 ExecutorService executor = Executors.newSingleThreadExecutor(); in test_SSLSocket_startHandshake_noKeyStore()
504 ExecutorService executor = Executors.newSingleThreadExecutor(); in test_SSLSocket_startHandshake_noClientCertificate()
524 ExecutorService executor = Executors.newSingleThreadExecutor(); in test_SSLSocket_HandshakeCompletedListener()
647 ExecutorService executor = Executors.newSingleThreadExecutor(); in test_SSLSocket_HandshakeCompletedListener_RuntimeException()
713 ExecutorService executor = Executors.newSingleThreadExecutor(); in test_SSLSocket_setUseClientMode()
767 ExecutorService executor = Executors.newSingleThreadExecutor(); in test_SSLSocket_untrustedServer()
[all …]
/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/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/tzdata/update_test_app/src/libcore/tzdata/update_test_app/installupdatetestapp/
DMainActivity.java40 import java.util.concurrent.Executors;
69 executor = Executors.newFixedThreadPool(1); in onCreate()
/libcore/ojluni/src/main/java/java/lang/
DUNIXProcess.java39 import java.util.concurrent.Executors;
121 return Executors.newCachedThreadPool
/libcore/luni/src/test/java/libcore/java/security/
DMessageDigestTest.java35 import java.util.concurrent.Executors;
255 ExecutorService es = Executors.newFixedThreadPool(THREAD_COUNT); in testMessageDigest_MultipleThreads_Misuse()
/libcore/ojluni/src/main/java/sun/nio/ch/
DThreadPool.java117 ExecutorService executor = Executors.newFixedThreadPool(nThreads, factory); in create()
/libcore/luni/src/main/java/java/util/concurrent/
DExecutors.java48 public class Executors { class
666 private Executors() {}
/libcore/support/src/test/java/tests/http/
DMockWebServer.java44 import java.util.concurrent.Executors;
177 executor = Executors.newCachedThreadPool(); in play()

12