Home
last modified time | relevance | path

Searched refs:ExecutorService (Results 1 – 25 of 51) sorted by relevance

123

/libcore/jsr166-tests/src/test/java/jsr166/
DAbstractExecutorServiceTest.java25 import java.util.concurrent.ExecutorService;
68 ExecutorService e = new DirectExecutorService(); in testExecuteRunnable()
85 ExecutorService e = new DirectExecutorService(); in testSubmitCallable()
95 ExecutorService e = new DirectExecutorService(); in testSubmitRunnable()
105 ExecutorService e = new DirectExecutorService(); in testSubmitRunnable2()
117 ExecutorService e = new DirectExecutorService(); in testSubmitPrivilegedAction()
138 ExecutorService e = new DirectExecutorService(); in testSubmitPrivilegedExceptionAction()
156 ExecutorService e = new DirectExecutorService(); in testSubmitFailedPrivilegedExceptionAction()
176 ExecutorService e = new DirectExecutorService(); in testExecuteNullRunnable()
187 ExecutorService e = new DirectExecutorService(); in testSubmitNullCallable()
[all …]
DExecutorsTest.java23 import java.util.concurrent.ExecutorService;
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.java17 import java.util.concurrent.ExecutorService;
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()
167 final ExecutorService e = in testNewTaskForCallable()
198 final ExecutorService e = in testNewTaskForRunnable()
DForkJoinPoolTest.java21 import java.util.concurrent.ExecutorService;
427 ExecutorService e = new ForkJoinPool(1); in testExecuteRunnable()
446 ExecutorService e = new ForkJoinPool(1); in testSubmitCallable()
459 ExecutorService e = new ForkJoinPool(1); in testSubmitRunnable()
472 ExecutorService e = new ForkJoinPool(1); in testSubmitRunnable2()
489 ExecutorService e = new ForkJoinPool(1); in testSubmitPrivilegedAction()
508 ExecutorService e = new ForkJoinPool(1); in testSubmitPrivilegedExceptionAction()
527 ExecutorService e = new ForkJoinPool(1); in testSubmitFailedPrivilegedExceptionAction()
546 ExecutorService e = new ForkJoinPool(1); in testExecuteNullRunnable()
559 ExecutorService e = new ForkJoinPool(1); in testSubmitNullCallable()
[all …]
DScheduledExecutorTest.java24 import java.util.concurrent.ExecutorService;
833 final ExecutorService e = new ScheduledThreadPoolExecutor(2); in testSubmitCallable()
845 final ExecutorService e = new ScheduledThreadPoolExecutor(2); in testSubmitRunnable()
857 final ExecutorService e = new ScheduledThreadPoolExecutor(2); in testSubmitRunnable2()
869 final ExecutorService e = new ScheduledThreadPoolExecutor(2); in testInvokeAny1()
882 final ExecutorService e = new ScheduledThreadPoolExecutor(2); in testInvokeAny2()
896 final ExecutorService e = new ScheduledThreadPoolExecutor(2); in testInvokeAny3()
913 final ExecutorService e = new ScheduledThreadPoolExecutor(2); in testInvokeAny4()
930 final ExecutorService e = new ScheduledThreadPoolExecutor(2); in testInvokeAny5()
944 final ExecutorService e = new ScheduledThreadPoolExecutor(2); in testInvokeAll1()
[all …]
DScheduledExecutorSubclassTest.java23 import java.util.concurrent.ExecutorService;
884 final ExecutorService e = new CustomExecutor(2); in testSubmitCallable()
896 final ExecutorService e = new CustomExecutor(2); in testSubmitRunnable()
908 final ExecutorService e = new CustomExecutor(2); in testSubmitRunnable2()
920 final ExecutorService e = new CustomExecutor(2); in testInvokeAny1()
933 final ExecutorService e = new CustomExecutor(2); in testInvokeAny2()
947 final ExecutorService e = new CustomExecutor(2); in testInvokeAny3()
964 final ExecutorService e = new CustomExecutor(2); in testInvokeAny4()
981 final ExecutorService e = new CustomExecutor(2); in testInvokeAny5()
995 final ExecutorService e = new CustomExecutor(2); in testInvokeAll1()
[all …]
DThreadPoolExecutorTest.java24 import java.util.concurrent.ExecutorService;
1438 final ExecutorService e = in testSubmitCallable()
1453 final ExecutorService e = in testSubmitRunnable()
1468 final ExecutorService e = in testSubmitRunnable2()
1483 final ExecutorService e = in testInvokeAny1()
1499 final ExecutorService e = in testInvokeAny2()
1516 final ExecutorService e = in testInvokeAny3()
1536 final ExecutorService e = in testInvokeAny4()
1556 final ExecutorService e = in testInvokeAny5()
1573 final ExecutorService e = in testInvokeAll1()
[all …]
DThreadPoolExecutorSubclassTest.java23 import java.util.concurrent.ExecutorService;
1431 final ExecutorService e = in testSubmitCallable()
1446 final ExecutorService e = in testSubmitRunnable()
1461 final ExecutorService e = in testSubmitRunnable2()
1476 final ExecutorService e = in testInvokeAny1()
1492 final ExecutorService e = in testInvokeAny2()
1509 final ExecutorService e = in testInvokeAny3()
1529 final ExecutorService e = in testInvokeAny4()
1549 final ExecutorService e = in testInvokeAny5()
1566 final ExecutorService e = in testInvokeAll1()
[all …]
DCollection8Test.java17 import java.util.concurrent.ExecutorService;
82 final ExecutorService pool = Executors.newCachedThreadPool(); in testForEachConcurrentStressTest()
DLongAccumulatorTest.java10 import java.util.concurrent.ExecutorService;
127 final ExecutorService pool = Executors.newCachedThreadPool(); in testAccumulateAndGetMT()
DDoubleAccumulatorTest.java10 import java.util.concurrent.ExecutorService;
127 final ExecutorService pool = Executors.newCachedThreadPool(); in testAccumulateAndGetMT()
DDoubleAdderTest.java11 import java.util.concurrent.ExecutorService;
139 final ExecutorService pool = Executors.newCachedThreadPool(); in testAddAndSumMT()
/libcore/ojluni/src/main/java/sun/nio/ch/
DThreadPool.java43 private final ExecutorService executor;
52 private ThreadPool(ExecutorService executor, in ThreadPool()
61 ExecutorService executor() { in executor()
121 ExecutorService executor = Executors.newCachedThreadPool(threadFactory); in createDefault()
129 ExecutorService executor = Executors.newFixedThreadPool(nThreads, factory); in create()
134 public static ThreadPool wrap(ExecutorService executor, int initialSize) { in wrap()
DAsynchronousFileChannelImpl.java30 import java.util.concurrent.ExecutorService;
55 protected final ExecutorService executor;
60 ExecutorService executor) in AsynchronousFileChannelImpl()
68 final ExecutorService executor() { in executor()
DLinuxAsynchronousChannelProvider.java30 import java.util.concurrent.ExecutorService;
61 …public AsynchronousChannelGroup openAsynchronousChannelGroup(ExecutorService executor, int initial… in openAsynchronousChannelGroup()
/libcore/ojluni/src/main/java/java/util/concurrent/
DExecutors.java95 public static ExecutorService newFixedThreadPool(int nThreads) { in newFixedThreadPool()
116 public static ExecutorService newWorkStealingPool(int parallelism) { in newWorkStealingPool()
132 public static ExecutorService newWorkStealingPool() { in newWorkStealingPool()
158 public static ExecutorService newFixedThreadPool(int nThreads, ThreadFactory threadFactory) { in newFixedThreadPool()
178 public static ExecutorService newSingleThreadExecutor() { in newSingleThreadExecutor()
199 public static ExecutorService newSingleThreadExecutor(ThreadFactory threadFactory) { in newSingleThreadExecutor()
223 public static ExecutorService newCachedThreadPool() { in newCachedThreadPool()
238 public static ExecutorService newCachedThreadPool(ThreadFactory threadFactory) { in newCachedThreadPool()
322 public static ExecutorService unconfigurableExecutorService(ExecutorService executor) { in unconfigurableExecutorService()
628 private final ExecutorService e;
[all …]
DScheduledExecutorService.java94 public interface ScheduledExecutorService extends ExecutorService {
/libcore/ojluni/annotations/hiddenapi/java/util/concurrent/
DExecutors.java47 public static java.util.concurrent.ExecutorService newFixedThreadPool(int nThreads) { in newFixedThreadPool()
51 public static java.util.concurrent.ExecutorService newWorkStealingPool(int parallelism) { in newWorkStealingPool()
55 public static java.util.concurrent.ExecutorService newWorkStealingPool() { in newWorkStealingPool()
59 public static java.util.concurrent.ExecutorService newFixedThreadPool( in newFixedThreadPool()
64 public static java.util.concurrent.ExecutorService newSingleThreadExecutor() { in newSingleThreadExecutor()
68 public static java.util.concurrent.ExecutorService newSingleThreadExecutor( in newSingleThreadExecutor()
73 public static java.util.concurrent.ExecutorService newCachedThreadPool() { in newCachedThreadPool()
77 public static java.util.concurrent.ExecutorService newCachedThreadPool( in newCachedThreadPool()
101 public static java.util.concurrent.ExecutorService unconfigurableExecutorService( in unconfigurableExecutorService()
102 java.util.concurrent.ExecutorService executor) { in unconfigurableExecutorService()
[all …]
/libcore/ojluni/src/main/java/java/nio/channels/
DAsynchronousChannelGroup.java30 import java.util.concurrent.ExecutorService;
228 public static AsynchronousChannelGroup withCachedThreadPool(ExecutorService executor, in withCachedThreadPool()
269 public static AsynchronousChannelGroup withThreadPool(ExecutorService executor) in withThreadPool()
DAsynchronousFileChannel.java34 import java.util.concurrent.ExecutorService;
243 ExecutorService executor, in open()
/libcore/luni/src/test/java/tests/security/
DSecureRandomTest.java23 import java.util.concurrent.ExecutorService;
79 ExecutorService executor = Executors.newFixedThreadPool(threads); in testSecureRandomThreadSafety()
/libcore/luni/src/test/java/libcore/java/security/
DMessageDigestTest.java27 import java.util.concurrent.ExecutorService;
37 ExecutorService es = Executors.newFixedThreadPool(THREAD_COUNT); in testMessageDigest_MultipleThreads_Misuse()
/libcore/support/src/test/java/tests/support/
DSupport_Exec.java31 import java.util.concurrent.ExecutorService;
85 ExecutorService executorService = Executors.newFixedThreadPool(2); in execAndGetOutput()
/libcore/support/src/test/java/libcore/javax/net/ssl/
DTestSSLSocketPair.java20 import java.util.concurrent.ExecutorService;
78 ExecutorService executor = Executors.newFixedThreadPool(2); in connect()
/libcore/luni/src/test/java/libcore/java/nio/channels/
DAsynchronousChannelGroupTest.java25 import java.util.concurrent.ExecutorService;
138 ExecutorService executorService = Executors.newFixedThreadPool(5); in test_isTerminated()

123