| /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),
|
| /libcore/luni/src/test/java/libcore/java/nio/channels/ |
| D | AsynchronousChannelGroupTest.java | 26 import java.util.concurrent.Executors;
59 Executors.newFixedThreadPool(5), 1); in test_withCachedThreadPool()
66 AsynchronousChannelGroup.withCachedThreadPool(Executors.newFixedThreadPool(5), -1); in test_withCachedThreadPool()
74 Executors.newFixedThreadPool(5)); in test_withThreadPool()
86 Executors.newFixedThreadPool(5), 1); in test_shutdown()
117 Executors.newFixedThreadPool(5), 1); in test_shutdownNow()
138 ExecutorService executorService = Executors.newFixedThreadPool(5); in test_isTerminated()
157 Executors.newFixedThreadPool(5), 1); in test_awaitTermination()
|
| D | AsynchronousServerSocketChannelTest.java | 39 import java.util.concurrent.Executors;
233 provider.openAsynchronousChannelGroup(2, Executors.defaultThreadFactory()); in test_group()
366 provider.openAsynchronousChannelGroup(2, Executors.defaultThreadFactory()); in test_closeGuardSupport_group()
|
| D | ServerSocketChannelTest.java | 43 import java.util.concurrent.Executors;
168 ExecutorService executor = Executors.newSingleThreadExecutor(); in bind_loopback()
|
| /libcore/luni/src/test/java/libcore/java/nio/channels/spi/ |
| D | AsynchronousChannelProviderTest.java | 23 import java.util.concurrent.Executors;
36 assertNotNull(provider.openAsynchronousChannelGroup(Executors.newSingleThreadExecutor(), in test_open_methods()
|
| /libcore/luni/src/test/java/libcore/sun/misc/ |
| D | UnsafeTest.java | 23 import java.util.concurrent.Executors;
42 Callable<Object> callable = Executors.callable(new Runnable() { in test_getUnsafeForbiddenWithSystemCaller()
|
| /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/java/security/ |
| D | MessageDigestTest.java | 28 import java.util.concurrent.Executors;
37 ExecutorService es = Executors.newFixedThreadPool(THREAD_COUNT); in testMessageDigest_MultipleThreads_Misuse()
|
| /libcore/ojluni/src/main/java/sun/nio/ch/ |
| D | ThreadPool.java | 121 ExecutorService executor = Executors.newCachedThreadPool(threadFactory); in createDefault()
129 ExecutorService executor = Executors.newFixedThreadPool(nThreads, factory); in create()
|
| /libcore/ojluni/annotations/hiddenapi/java/util/concurrent/ |
| D | Executors.java | 41 public class Executors { class
43 private Executors() { in Executors() method in Executors
268 extends java.util.concurrent.Executors.DelegatedExecutorService
313 extends java.util.concurrent.Executors.DelegatedExecutorService {
382 extends java.util.concurrent.Executors.DefaultThreadFactory {
|
| /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()
|
| /libcore/support/src/test/java/libcore/javax/net/ssl/ |
| D | TestSSLSocketPair.java | 21 import java.util.concurrent.Executors;
78 ExecutorService executor = Executors.newFixedThreadPool(2); in connect()
|
| /libcore/luni/src/test/java/libcore/java/util/zip/ |
| D | DeflaterOutputStreamTest.java | 30 import java.util.concurrent.Executors;
76 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/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/libcore/net/ |
| D | NetworkSecurityPolicyTest.java | 33 import java.util.concurrent.Executors;
279 executor = Executors.newSingleThreadExecutor(); in CapturingServerSocket()
|
| /libcore/ojluni/src/main/java/java/util/concurrent/ |
| D | Executors.java | 78 public class Executors { class
705 private Executors() {}
|