/libcore/ojluni/src/test/java/util/concurrent/tck/ |
D | ThreadPoolExecutorTest.java | 58 import java.util.concurrent.ThreadPoolExecutor; 72 static class ExtendedTPE extends ThreadPoolExecutor { 113 final ThreadPoolExecutor p = in testExecute() 114 new ThreadPoolExecutor(1, 1, in testExecute() 132 final ThreadPoolExecutor p = in testGetActiveCount() 133 new ThreadPoolExecutor(2, 2, in testGetActiveCount() 154 final ThreadPoolExecutor p = in testPrestartCoreThread() 155 new ThreadPoolExecutor(2, 6, in testPrestartCoreThread() 180 final ThreadPoolExecutor p = in testPrestartAllCoreThreads() 181 new ThreadPoolExecutor(2, 6, in testPrestartAllCoreThreads() [all …]
|
D | ThreadPoolExecutorSubclassTest.java | 57 import java.util.concurrent.ThreadPoolExecutor; 174 static class CustomTPE extends ThreadPoolExecutor { 260 final ThreadPoolExecutor p = in testExecute() 279 final ThreadPoolExecutor p = in testGetActiveCount() 301 final ThreadPoolExecutor p = in testPrestartCoreThread() 327 final ThreadPoolExecutor p = in testPrestartAllCoreThreads() 350 final ThreadPoolExecutor p = in testGetCompletedTaskCount() 383 final ThreadPoolExecutor p = in testGetCorePoolSize() 396 final ThreadPoolExecutor p = in testGetKeepAliveTime() 410 final ThreadPoolExecutor p = in testGetThreadFactory() [all …]
|
D | ExecutorCompletionServiceTest.java | 49 import java.util.concurrent.ThreadPoolExecutor; 229 new ThreadPoolExecutor(1, 1, in testNewTaskForCallable() 259 new ThreadPoolExecutor(1, 1, in testNewTaskForRunnable()
|
D | AbstractExecutorServiceTest.java | 53 import java.util.concurrent.ThreadPoolExecutor; 229 = new ThreadPoolExecutor(1,1,60, TimeUnit.SECONDS, in testInterruptedSubmit() 250 final ThreadPoolExecutor p = in testSubmitEE() 251 new ThreadPoolExecutor(1, 1, in testSubmitEE()
|
D | ScheduledExecutorSubclassTest.java | 56 import java.util.concurrent.ThreadPoolExecutor; 419 final ThreadPoolExecutor p = new CustomExecutor(2); in testGetActiveCount() 439 final ThreadPoolExecutor p = new CustomExecutor(2); in testGetCompletedTaskCount() 482 final ThreadPoolExecutor p = new CustomExecutor(THREADS); in testGetLargestPoolSize() 505 final ThreadPoolExecutor p = new CustomExecutor(1); in testGetPoolSize() 527 final ThreadPoolExecutor p = new CustomExecutor(1); in testGetTaskCount() 609 final ThreadPoolExecutor p = new CustomExecutor(1); in testIsTerminated() 633 final ThreadPoolExecutor p = new CustomExecutor(1); in testIsTerminating()
|
D | ScheduledExecutorTest.java | 55 import java.util.concurrent.ThreadPoolExecutor; 383 final ThreadPoolExecutor p = new ScheduledThreadPoolExecutor(2); in testGetCompletedTaskCount() 413 ThreadPoolExecutor p = new ScheduledThreadPoolExecutor(1); in testGetCorePoolSize() 425 final ThreadPoolExecutor p = new ScheduledThreadPoolExecutor(THREADS); in testGetLargestPoolSize() 448 final ThreadPoolExecutor p = new ScheduledThreadPoolExecutor(1); in testGetPoolSize() 471 final ThreadPoolExecutor p = new ScheduledThreadPoolExecutor(1); in testGetTaskCount() 555 final ThreadPoolExecutor p = new ScheduledThreadPoolExecutor(1); in testIsTerminated() 579 final ThreadPoolExecutor p = new ScheduledThreadPoolExecutor(1); in testIsTerminating()
|
D | ExecutorsTest.java | 52 import java.util.concurrent.ThreadPoolExecutor; 140 ThreadPoolExecutor tpe = (ThreadPoolExecutor)e; in testCastNewSingleThreadExecutor()
|
D | JSR166TestCase.java | 118 import java.util.concurrent.ThreadPoolExecutor; 1856 ThreadPoolExecutor executor) {} 2030 new ThreadPoolExecutor(0, Integer.MAX_VALUE,
|
/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/api/ |
D | current.txt | 14946 method public void rejectedExecution(Runnable, java.util.concurrent.ThreadPoolExecutor); 14966 …public class ScheduledThreadPoolExecutor extends java.util.concurrent.ThreadPoolExecutor implement… 15037 public class ThreadPoolExecutor extends java.util.concurrent.AbstractExecutorService { 15038 …ctor public ThreadPoolExecutor(int, int, long, java.util.concurrent.TimeUnit, java.util.concurrent… 15039 …ctor public ThreadPoolExecutor(int, int, long, java.util.concurrent.TimeUnit, java.util.concurrent… 15040 …ctor public ThreadPoolExecutor(int, int, long, java.util.concurrent.TimeUnit, java.util.concurrent… 15041 …ctor public ThreadPoolExecutor(int, int, long, java.util.concurrent.TimeUnit, java.util.concurrent… 15077 …public static class ThreadPoolExecutor.AbortPolicy implements java.util.concurrent.RejectedExecuti… 15078 ctor public ThreadPoolExecutor.AbortPolicy(); 15079 method public void rejectedExecution(Runnable, java.util.concurrent.ThreadPoolExecutor); [all …]
|
/libcore/ |
D | openjdk_java_files.bp | 985 "ojluni/src/main/java/java/util/concurrent/ThreadPoolExecutor.java",
|