Home
last modified time | relevance | path

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

/libcore/luni/src/test/java/tests/api/java/util/concurrent/
DExecutorsTest.java27 ExecutorService e = Executors.newCachedThreadPool(); in testNewCachedThreadPool1()
38 ExecutorService e = Executors.newCachedThreadPool(new SimpleThreadFactory()); in testNewCachedThreadPool2()
50 ExecutorService e = Executors.newCachedThreadPool(null); in testNewCachedThreadPool3()
60 ExecutorService e = Executors.newSingleThreadExecutor(); in testNewSingleThreadExecutor1()
71 ExecutorService e = Executors.newSingleThreadExecutor(new SimpleThreadFactory()); in testNewSingleThreadExecutor2()
83 ExecutorService e = Executors.newSingleThreadExecutor(null); in testNewSingleThreadExecutor3()
92 ExecutorService e = Executors.newSingleThreadExecutor(); in testCastNewSingleThreadExecutor()
107 ExecutorService e = Executors.newFixedThreadPool(2); in testNewFixedThreadPool1()
118 ExecutorService e = Executors.newFixedThreadPool(2, new SimpleThreadFactory()); in testNewFixedThreadPool2()
130 ExecutorService e = Executors.newFixedThreadPool(2, null); in testNewFixedThreadPool3()
[all …]
DExecutorCompletionServiceTest.java40 ExecutorService e = Executors.newCachedThreadPool(); in testConstructorNPE2()
50 ExecutorService e = Executors.newCachedThreadPool(); in testSubmitNPE()
66 ExecutorService e = Executors.newCachedThreadPool(); in testSubmitNPE2()
82 ExecutorService e = Executors.newCachedThreadPool(); in testTake()
98 ExecutorService e = Executors.newCachedThreadPool(); in testTake2()
114 ExecutorService e = Executors.newCachedThreadPool(); in testPoll1()
137 ExecutorService e = Executors.newCachedThreadPool(); in testPoll2()
DAbstractExecutorServiceTest.java88 Future future = e.submit(Executors.callable(new PrivilegedAction() { in testSubmitPrivilegedAction()
109 Future future = e.submit(Executors.callable(new PrivilegedExceptionAction() { in testSubmitPrivilegedExceptionAction()
127 Future future = e.submit(Executors.callable(new PrivilegedExceptionAction() { in testSubmitFailedPrivilegedExceptionAction()
647 l.add(Executors.callable(new MediumPossiblyInterruptedRunnable(), TEST_STRING)); in testTimedInvokeAll6()
DSynchronousQueueTest.java564 ExecutorService executor = Executors.newFixedThreadPool(2); in testOfferInExecutor()
587 ExecutorService executor = Executors.newFixedThreadPool(2); in testPollInExecutor()
DArrayBlockingQueueTest.java755 ExecutorService executor = Executors.newFixedThreadPool(2); in testOfferInExecutor()
777 ExecutorService executor = Executors.newFixedThreadPool(2); in testPollInExecutor()
DLinkedBlockingQueueTest.java754 ExecutorService executor = Executors.newFixedThreadPool(2); in testOfferInExecutor()
776 ExecutorService executor = Executors.newFixedThreadPool(2); in testPollInExecutor()
DLinkedBlockingDequeTest.java1506 ExecutorService executor = Executors.newFixedThreadPool(2); in testOfferInExecutor()
1528 ExecutorService executor = Executors.newFixedThreadPool(2); in testPollInExecutor()
DDelayQueueTest.java740 ExecutorService executor = Executors.newFixedThreadPool(2); in testPollInExecutor()
DPriorityBlockingQueueTest.java698 ExecutorService executor = Executors.newFixedThreadPool(2); in testPollInExecutor()
DScheduledExecutorTest.java992 l.add(Executors.callable(new MediumPossiblyInterruptedRunnable(), TEST_STRING));
DScheduledExecutorSubclassTest.java1041 l.add(Executors.callable(new MediumPossiblyInterruptedRunnable(), TEST_STRING));
DThreadPoolExecutorSubclassTest.java1504 l.add(Executors.callable(new MediumPossiblyInterruptedRunnable(), TEST_STRING)); in testTimedInvokeAll6()
DThreadPoolExecutorTest.java1375 l.add(Executors.callable(new MediumPossiblyInterruptedRunnable(), TEST_STRING)); in testTimedInvokeAll6()
/libcore/luni/src/test/java/sun/misc/
DUnsafeTest.java22 import java.util.concurrent.Executors;
39 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/support/src/test/java/libcore/javax/net/ssl/
DTestSSLSocketPair.java21 import java.util.concurrent.Executors;
67 ExecutorService executor = Executors.newFixedThreadPool(2); in connect()
/libcore/luni/src/test/java/libcore/java/util/zip/
DDeflaterOutputStreamTest.java29 import java.util.concurrent.Executors;
69 ExecutorService executor = Executors.newSingleThreadExecutor(); in createInflaterStream()
/libcore/luni/src/main/java/java/util/concurrent/
DFutureTask.java64 sync = new Sync(Executors.callable(runnable, result)); in FutureTask()
DExecutors.java44 public class Executors { class
682 private Executors() {}
DThreadPoolExecutor.java1142 Executors.defaultThreadFactory(), defaultHandler); in ThreadPoolExecutor()
1212 Executors.defaultThreadFactory(), handler); in ThreadPoolExecutor()
DScheduledThreadPoolExecutor.java608 return schedule(Executors.callable(task, result), in submit()
/libcore/support/src/test/java/tests/http/
DMockWebServer.java42 import java.util.concurrent.Executors;
154 executor = Executors.newCachedThreadPool(); in play()
/libcore/luni/src/test/java/org/apache/harmony/luni/tests/internal/net/www/protocol/https/
DHttpsURLConnectionTest.java42 import java.util.concurrent.Executors;
755 ExecutorService executorService = Executors.newFixedThreadPool(2); in doInteraction()
/libcore/luni/src/test/java/org/apache/harmony/xnet/provider/jsse/
DNativeCryptoTest.java38 import java.util.concurrent.Executors;
557 ExecutorService executor = Executors.newSingleThreadExecutor(); in handshake()