Home
last modified time | relevance | path

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

1234

/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 …]
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 …]
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 …]
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 …]
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 …]
/libcore/ojluni/src/test/java/util/concurrent/tck/
DAbstractExecutorServiceTest.java51 import java.util.concurrent.ExecutorService;
91 ExecutorService e = new DirectExecutorService(); in testExecuteRunnable()
108 ExecutorService e = new DirectExecutorService(); in testSubmitCallable()
118 ExecutorService e = new DirectExecutorService(); in testSubmitRunnable()
128 ExecutorService e = new DirectExecutorService(); in testSubmitRunnable2()
140 ExecutorService e = new DirectExecutorService(); in testSubmitPrivilegedAction()
161 ExecutorService e = new DirectExecutorService(); in testSubmitPrivilegedExceptionAction()
179 ExecutorService e = new DirectExecutorService(); in testSubmitFailedPrivilegedExceptionAction()
199 ExecutorService e = new DirectExecutorService(); in testExecuteNullRunnable()
210 ExecutorService e = new DirectExecutorService(); in testSubmitNullCallable()
[all …]
DExecutorsTest.java49 import java.util.concurrent.ExecutorService;
69 final ExecutorService e = Executors.newCachedThreadPool(); in testNewCachedThreadPool1()
81 final ExecutorService e = Executors.newCachedThreadPool(new SimpleThreadFactory()); in testNewCachedThreadPool2()
94 ExecutorService e = Executors.newCachedThreadPool(null); in testNewCachedThreadPool3()
103 final ExecutorService e = Executors.newSingleThreadExecutor(); in testNewSingleThreadExecutor1()
115 final ExecutorService e = Executors.newSingleThreadExecutor(new SimpleThreadFactory()); in testNewSingleThreadExecutor2()
128 ExecutorService e = Executors.newSingleThreadExecutor(null); in testNewSingleThreadExecutor3()
137 final ExecutorService e = Executors.newSingleThreadExecutor(); in testCastNewSingleThreadExecutor()
150 final ExecutorService e = Executors.newFixedThreadPool(2); in testNewFixedThreadPool1()
162 final ExecutorService e = Executors.newFixedThreadPool(2, new SimpleThreadFactory()); in testNewFixedThreadPool2()
[all …]
DForkJoinPoolTest.java47 import java.util.concurrent.ExecutorService;
445 ExecutorService e = new ForkJoinPool(1); in testExecuteRunnable()
464 ExecutorService e = new ForkJoinPool(1); in testSubmitCallable()
477 ExecutorService e = new ForkJoinPool(1); in testSubmitRunnable()
490 ExecutorService e = new ForkJoinPool(1); in testSubmitRunnable2()
507 ExecutorService e = new ForkJoinPool(1); in testSubmitPrivilegedAction()
526 ExecutorService e = new ForkJoinPool(1); in testSubmitPrivilegedExceptionAction()
545 ExecutorService e = new ForkJoinPool(1); in testSubmitFailedPrivilegedExceptionAction()
564 ExecutorService e = new ForkJoinPool(1); in testExecuteNullRunnable()
577 ExecutorService e = new ForkJoinPool(1); in testSubmitNullCallable()
[all …]
DScheduledExecutorSubclassTest.java48 import java.util.concurrent.ExecutorService;
906 final ExecutorService e = new CustomExecutor(2); in testSubmitCallable()
918 final ExecutorService e = new CustomExecutor(2); in testSubmitRunnable()
930 final ExecutorService e = new CustomExecutor(2); in testSubmitRunnable2()
942 final ExecutorService e = new CustomExecutor(2); in testInvokeAny1()
955 final ExecutorService e = new CustomExecutor(2); in testInvokeAny2()
969 final ExecutorService e = new CustomExecutor(2); in testInvokeAny3()
986 final ExecutorService e = new CustomExecutor(2); in testInvokeAny4()
1003 final ExecutorService e = new CustomExecutor(2); in testInvokeAny5()
1017 final ExecutorService e = new CustomExecutor(2); in testInvokeAll1()
[all …]
DScheduledExecutorTest.java49 import java.util.concurrent.ExecutorService;
854 final ExecutorService e = new ScheduledThreadPoolExecutor(2); in testSubmitCallable()
866 final ExecutorService e = new ScheduledThreadPoolExecutor(2); in testSubmitRunnable()
878 final ExecutorService e = new ScheduledThreadPoolExecutor(2); in testSubmitRunnable2()
890 final ExecutorService e = new ScheduledThreadPoolExecutor(2); in testInvokeAny1()
903 final ExecutorService e = new ScheduledThreadPoolExecutor(2); in testInvokeAny2()
917 final ExecutorService e = new ScheduledThreadPoolExecutor(2); in testInvokeAny3()
934 final ExecutorService e = new ScheduledThreadPoolExecutor(2); in testInvokeAny4()
951 final ExecutorService e = new ScheduledThreadPoolExecutor(2); in testInvokeAny5()
965 final ExecutorService e = new ScheduledThreadPoolExecutor(2); in testInvokeAll1()
[all …]
DThreadPoolExecutorSubclassTest.java48 import java.util.concurrent.ExecutorService;
1453 final ExecutorService e = in testSubmitCallable()
1468 final ExecutorService e = in testSubmitRunnable()
1483 final ExecutorService e = in testSubmitRunnable2()
1498 final ExecutorService e = in testInvokeAny1()
1514 final ExecutorService e = in testInvokeAny2()
1531 final ExecutorService e = in testInvokeAny3()
1551 final ExecutorService e = in testInvokeAny4()
1571 final ExecutorService e = in testInvokeAny5()
1588 final ExecutorService e = in testInvokeAll1()
[all …]
DThreadPoolExecutorTest.java50 import java.util.concurrent.ExecutorService;
1455 final ExecutorService e = in testSubmitCallable()
1470 final ExecutorService e = in testSubmitRunnable()
1485 final ExecutorService e = in testSubmitRunnable2()
1500 final ExecutorService e = in testInvokeAny1()
1516 final ExecutorService e = in testInvokeAny2()
1533 final ExecutorService e = in testInvokeAny3()
1553 final ExecutorService e = in testInvokeAny4()
1573 final ExecutorService e = in testInvokeAny5()
1590 final ExecutorService e = in testInvokeAll1()
[all …]
/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 …]
/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/luni/src/test/java/libcore/java/util/concurrent/
DExecutorServiceAutoCloseable.java21 import java.util.concurrent.ExecutorService;
25 private final ExecutorService service;
27 public ExecutorServiceAutoCloseable(ExecutorService service) { in ExecutorServiceAutoCloseable()
DExecutorsTest.java20 import java.util.concurrent.ExecutorService;
34 final ExecutorService e = Executors.newWorkStealingPool(); in testNewWorkStealingPoolDefault()
44 final ExecutorService e = Executors.newWorkStealingPool(2); in testNewWorkStealingPoolWithParallelism()
DAbstractExecutorServiceTest.java25 import java.util.concurrent.ExecutorService;
74 ExecutorService service = new TestExecutorService(); in testSubmitRunnableWithValue()
/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()
/libcore/luni/src/test/java/tests/security/
DSecureRandomTest.java23 import java.util.concurrent.ExecutorService;
79 ExecutorService executor = Executors.newFixedThreadPool(threads); in testSecureRandomThreadSafety()

1234