| /libcore/jsr166-tests/src/test/java/jsr166/ |
| D | ThreadPoolExecutorTest.java | 32 import java.util.concurrent.ThreadPoolExecutor;
50 static class ExtendedTPE extends ThreadPoolExecutor {
91 final ThreadPoolExecutor p = in testExecute()
92 new ThreadPoolExecutor(1, 1, in testExecute()
110 final ThreadPoolExecutor p = in testGetActiveCount()
111 new ThreadPoolExecutor(2, 2, in testGetActiveCount()
132 final ThreadPoolExecutor p = in testPrestartCoreThread()
133 new ThreadPoolExecutor(2, 6, in testPrestartCoreThread()
158 final ThreadPoolExecutor p = in testPrestartAllCoreThreads()
159 new ThreadPoolExecutor(2, 6, in testPrestartAllCoreThreads()
[all …]
|
| D | ThreadPoolExecutorSubclassTest.java | 32 import java.util.concurrent.ThreadPoolExecutor;
152 static class CustomTPE extends ThreadPoolExecutor {
238 final ThreadPoolExecutor p = in testExecute()
257 final ThreadPoolExecutor p = in testGetActiveCount()
279 final ThreadPoolExecutor p = in testPrestartCoreThread()
305 final ThreadPoolExecutor p = in testPrestartAllCoreThreads()
328 final ThreadPoolExecutor p = in testGetCompletedTaskCount()
361 final ThreadPoolExecutor p = in testGetCorePoolSize()
374 final ThreadPoolExecutor p = in testGetKeepAliveTime()
388 final ThreadPoolExecutor p = in testGetThreadFactory()
[all …]
|
| D | ExecutorCompletionServiceTest.java | 21 import java.util.concurrent.ThreadPoolExecutor;
168 new ThreadPoolExecutor(1, 1, in testNewTaskForCallable()
199 new ThreadPoolExecutor(1, 1, in testNewTaskForRunnable()
|
| D | AbstractExecutorServiceTest.java | 27 import java.util.concurrent.ThreadPoolExecutor;
206 = new ThreadPoolExecutor(1,1,60, TimeUnit.SECONDS, in testInterruptedSubmit()
227 final ThreadPoolExecutor p = in testSubmitEE()
228 new ThreadPoolExecutor(1, 1, in testSubmitEE()
|
| D | ExecutorsTest.java | 26 import java.util.concurrent.ThreadPoolExecutor;
117 ThreadPoolExecutor tpe = (ThreadPoolExecutor)e; in testCastNewSingleThreadExecutor()
|
| D | ScheduledExecutorSubclassTest.java | 31 import java.util.concurrent.ThreadPoolExecutor;
397 final ThreadPoolExecutor p = new CustomExecutor(2); in testGetActiveCount()
417 final ThreadPoolExecutor p = new CustomExecutor(2); in testGetCompletedTaskCount()
460 final ThreadPoolExecutor p = new CustomExecutor(THREADS); in testGetLargestPoolSize()
483 final ThreadPoolExecutor p = new CustomExecutor(1); in testGetPoolSize()
505 final ThreadPoolExecutor p = new CustomExecutor(1); in testGetTaskCount()
587 final ThreadPoolExecutor p = new CustomExecutor(1); in testIsTerminated()
611 final ThreadPoolExecutor p = new CustomExecutor(1); in testIsTerminating()
|
| D | ScheduledExecutorTest.java | 30 import java.util.concurrent.ThreadPoolExecutor;
361 final ThreadPoolExecutor p = new ScheduledThreadPoolExecutor(2); in testGetCompletedTaskCount()
391 ThreadPoolExecutor p = new ScheduledThreadPoolExecutor(1); in testGetCorePoolSize()
403 final ThreadPoolExecutor p = new ScheduledThreadPoolExecutor(THREADS); in testGetLargestPoolSize()
426 final ThreadPoolExecutor p = new ScheduledThreadPoolExecutor(1); in testGetPoolSize()
449 final ThreadPoolExecutor p = new ScheduledThreadPoolExecutor(1); in testGetTaskCount()
534 final ThreadPoolExecutor p = new ScheduledThreadPoolExecutor(1); in testIsTerminated()
558 final ThreadPoolExecutor p = new ScheduledThreadPoolExecutor(1); in testIsTerminating()
|
| D | JSR166TestCase.java | 52 import java.util.concurrent.ThreadPoolExecutor;
1707 ThreadPoolExecutor executor) {}
|
| /libcore/luni/src/test/java/libcore/java/util/concurrent/ |
| D | ThreadPoolExecutorTest.java | 22 import java.util.concurrent.ThreadPoolExecutor;
29 ThreadPoolExecutor tp = new ThreadPoolExecutor( in testCorePoolSizeGreaterThanMax()
|
| /libcore/ojluni/src/main/java/sun/nio/ch/ |
| D | ThreadPool.java | 106 new ThreadPoolExecutor(0, Integer.MAX_VALUE, in createDefault()
126 if (executor instanceof ThreadPoolExecutor) { in wrap()
127 int max = ((ThreadPoolExecutor)executor).getMaximumPoolSize(); in wrap()
|
| /libcore/luni/src/main/java/java/util/concurrent/ |
| D | Executors.java | 66 return new ThreadPoolExecutor(nThreads, nThreads, in newFixedThreadPool()
129 return new ThreadPoolExecutor(nThreads, nThreads, in newFixedThreadPool()
150 (new ThreadPoolExecutor(1, 1, in newSingleThreadExecutor()
171 (new ThreadPoolExecutor(1, 1, in newSingleThreadExecutor()
194 return new ThreadPoolExecutor(0, Integer.MAX_VALUE, in newCachedThreadPool()
209 return new ThreadPoolExecutor(0, Integer.MAX_VALUE, in newCachedThreadPool()
|
| D | RejectedExecutionHandler.java | 32 void rejectedExecution(Runnable r, ThreadPoolExecutor executor); in rejectedExecution()
|
| D | ThreadPoolExecutor.java | 309 public class ThreadPoolExecutor extends AbstractExecutorService { class
1181 public ThreadPoolExecutor(int corePoolSize, in ThreadPoolExecutor() method in ThreadPoolExecutor
1215 public ThreadPoolExecutor(int corePoolSize, in ThreadPoolExecutor() method in ThreadPoolExecutor
1250 public ThreadPoolExecutor(int corePoolSize, in ThreadPoolExecutor() method in ThreadPoolExecutor
1287 public ThreadPoolExecutor(int corePoolSize, in ThreadPoolExecutor() method in ThreadPoolExecutor
2024 public void rejectedExecution(Runnable r, ThreadPoolExecutor e) { in rejectedExecution()
2048 public void rejectedExecution(Runnable r, ThreadPoolExecutor e) { in rejectedExecution()
2071 public void rejectedExecution(Runnable r, ThreadPoolExecutor e) { in rejectedExecution()
2095 public void rejectedExecution(Runnable r, ThreadPoolExecutor e) { in rejectedExecution()
|
| D | ScheduledThreadPoolExecutor.java | 102 extends ThreadPoolExecutor
|
| /libcore/ |
| D | non_openjdk_java_files.mk | 140 luni/src/main/java/java/util/concurrent/ThreadPoolExecutor.java \
|