/libcore/jsr166-tests/src/test/java/jsr166/ |
D | ExecutorsTest.java | 22 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 …]
|
D | ExecutorCompletionServiceTest.java | 16 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()
|
D | Collection8Test.java | 16 import java.util.concurrent.Executors; 82 final ExecutorService pool = Executors.newCachedThreadPool(); in testForEachConcurrentStressTest()
|
D | LongAccumulatorTest.java | 9 import java.util.concurrent.Executors; 127 final ExecutorService pool = Executors.newCachedThreadPool(); in testAccumulateAndGetMT()
|
D | DoubleAccumulatorTest.java | 9 import java.util.concurrent.Executors; 127 final ExecutorService pool = Executors.newCachedThreadPool(); in testAccumulateAndGetMT()
|
D | DoubleAdderTest.java | 10 import java.util.concurrent.Executors; 139 final ExecutorService pool = Executors.newCachedThreadPool(); in testAddAndSumMT()
|
D | LongAdderTest.java | 10 import java.util.concurrent.Executors; 162 final ExecutorService pool = Executors.newCachedThreadPool(); in testAddAndSumMT()
|
D | AbstractExecutorServiceTest.java | 24 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),
|
D | SynchronousQueueTest.java | 20 import java.util.concurrent.Executors; 481 final ExecutorService executor = Executors.newFixedThreadPool(2); 508 final ExecutorService executor = Executors.newFixedThreadPool(2);
|
D | ForkJoinPoolTest.java | 20 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()
|
D | LinkedBlockingQueueTest.java | 21 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/ |
D | UnsafeTest.java | 23 import java.util.concurrent.Executors; 40 Callable<Object> callable = Executors.callable(new Runnable() { in test_getUnsafeForbiddenWithSystemCaller()
|
/libcore/support/src/test/java/tests/support/ |
D | Support_Exec.java | 32 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/ |
D | SecureRandomTest.java | 24 import java.util.concurrent.Executors; 79 ExecutorService executor = Executors.newFixedThreadPool(threads); in testSecureRandomThreadSafety()
|
/libcore/luni/src/test/java/libcore/javax/net/ssl/ |
D | SSLSocketTest.java | 46 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/ |
D | TestSSLSocketPair.java | 22 import java.util.concurrent.Executors; 79 ExecutorService executor = Executors.newFixedThreadPool(2); in connect()
|
/libcore/luni/src/test/java/libcore/java/util/zip/ |
D | DeflaterOutputStreamTest.java | 31 import java.util.concurrent.Executors; 72 ExecutorService executor = Executors.newSingleThreadExecutor(); in createInflaterStream()
|
/libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/io/ |
D | OutputStreamTesterTest.java | 42 import java.util.concurrent.Executors; 123 executor = Executors.newSingleThreadExecutor(); in create()
|
D | WriterTesterTest.java | 41 import java.util.concurrent.Executors; 116 executor = Executors.newSingleThreadExecutor(); in create()
|
/libcore/tzdata/update_test_app/src/libcore/tzdata/update_test_app/installupdatetestapp/ |
D | MainActivity.java | 40 import java.util.concurrent.Executors; 69 executor = Executors.newFixedThreadPool(1); in onCreate()
|
/libcore/ojluni/src/main/java/java/lang/ |
D | UNIXProcess.java | 39 import java.util.concurrent.Executors; 121 return Executors.newCachedThreadPool
|
/libcore/luni/src/test/java/libcore/java/security/ |
D | MessageDigestTest.java | 35 import java.util.concurrent.Executors; 255 ExecutorService es = Executors.newFixedThreadPool(THREAD_COUNT); in testMessageDigest_MultipleThreads_Misuse()
|
/libcore/ojluni/src/main/java/sun/nio/ch/ |
D | ThreadPool.java | 117 ExecutorService executor = Executors.newFixedThreadPool(nThreads, factory); in create()
|
/libcore/luni/src/main/java/java/util/concurrent/ |
D | Executors.java | 48 public class Executors { class 666 private Executors() {}
|
/libcore/support/src/test/java/tests/http/ |
D | MockWebServer.java | 44 import java.util.concurrent.Executors; 177 executor = Executors.newCachedThreadPool(); in play()
|