| /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 | 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 | ExecutorsTest.java | 26 import java.util.concurrent.ThreadPoolExecutor;
117 ThreadPoolExecutor tpe = (ThreadPoolExecutor)e; in testCastNewSingleThreadExecutor()
|
| D | JSR166TestCase.java | 52 import java.util.concurrent.ThreadPoolExecutor;
1747 ThreadPoolExecutor executor) {}
|
| /libcore/ojluni/annotations/hiddenapi/java/util/concurrent/ |
| D | ThreadPoolExecutor.java | 41 public class ThreadPoolExecutor extends java.util.concurrent.AbstractExecutorService { class
43 public ThreadPoolExecutor( in ThreadPoolExecutor() method in ThreadPoolExecutor
52 public ThreadPoolExecutor( in ThreadPoolExecutor() method in ThreadPoolExecutor
62 public ThreadPoolExecutor( in ThreadPoolExecutor() method in ThreadPoolExecutor
72 public ThreadPoolExecutor( in ThreadPoolExecutor() method in ThreadPoolExecutor
163 private void addWorkerFailed(java.util.concurrent.ThreadPoolExecutor.Worker w) { in addWorkerFailed()
168 java.util.concurrent.ThreadPoolExecutor.Worker w, boolean completedAbruptly) { in processWorkerExit()
176 final void runWorker(java.util.concurrent.ThreadPoolExecutor.Worker w) { in runWorker()
393 private final java.util.HashSet<java.util.concurrent.ThreadPoolExecutor.Worker> workers;
407 java.lang.Runnable r, java.util.concurrent.ThreadPoolExecutor e) { in rejectedExecution()
[all …]
|
| /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/java/util/concurrent/ |
| D | Executors.java | 96 return new ThreadPoolExecutor(nThreads, nThreads, in newFixedThreadPool()
159 return new ThreadPoolExecutor(nThreads, nThreads, in newFixedThreadPool()
180 (new ThreadPoolExecutor(1, 1, in newSingleThreadExecutor()
201 (new ThreadPoolExecutor(1, 1, in newSingleThreadExecutor()
224 return new ThreadPoolExecutor(0, Integer.MAX_VALUE, in newCachedThreadPool()
239 return new ThreadPoolExecutor(0, Integer.MAX_VALUE, in newCachedThreadPool()
|
| D | ThreadPoolExecutor.java | 339 public class ThreadPoolExecutor extends AbstractExecutorService { class
1215 public ThreadPoolExecutor(int corePoolSize, in ThreadPoolExecutor() method in ThreadPoolExecutor
1249 public ThreadPoolExecutor(int corePoolSize, in ThreadPoolExecutor() method in ThreadPoolExecutor
1284 public ThreadPoolExecutor(int corePoolSize, in ThreadPoolExecutor() method in ThreadPoolExecutor
1321 public ThreadPoolExecutor(int corePoolSize, in ThreadPoolExecutor() method in ThreadPoolExecutor
2059 public void rejectedExecution(Runnable r, ThreadPoolExecutor e) { in rejectedExecution()
2083 public void rejectedExecution(Runnable r, ThreadPoolExecutor e) { in rejectedExecution()
2106 public void rejectedExecution(Runnable r, ThreadPoolExecutor e) { in rejectedExecution()
2130 public void rejectedExecution(Runnable r, ThreadPoolExecutor e) { in rejectedExecution()
|
| D | RejectedExecutionHandler.java | 61 void rejectedExecution(Runnable r, ThreadPoolExecutor executor); in rejectedExecution()
|
| D | ScheduledThreadPoolExecutor.java | 131 extends ThreadPoolExecutor
|
| /libcore/ojluni/src/main/java/sun/nio/ch/ |
| D | ThreadPool.java | 138 if (executor instanceof ThreadPoolExecutor) { in wrap()
139 int max = ((ThreadPoolExecutor)executor).getMaximumPoolSize(); in wrap()
|
| /libcore/ |
| D | openjdk_java_files.bp | 977 "ojluni/src/main/java/java/util/concurrent/ThreadPoolExecutor.java",
|