Home
last modified time | relevance | path

Searched refs:ThreadPoolExecutor (Results 1 – 25 of 26) sorted by relevance

12

/libcore/jsr166-tests/src/test/java/jsr166/
DThreadPoolExecutorTest.java32 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 …]
DThreadPoolExecutorSubclassTest.java32 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 …]
DExecutorCompletionServiceTest.java21 import java.util.concurrent.ThreadPoolExecutor;
168 new ThreadPoolExecutor(1, 1, in testNewTaskForCallable()
199 new ThreadPoolExecutor(1, 1, in testNewTaskForRunnable()
DAbstractExecutorServiceTest.java27 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()
DScheduledExecutorSubclassTest.java31 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()
DScheduledExecutorTest.java30 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()
DExecutorsTest.java26 import java.util.concurrent.ThreadPoolExecutor;
117 ThreadPoolExecutor tpe = (ThreadPoolExecutor)e; in testCastNewSingleThreadExecutor()
DJSR166TestCase.java52 import java.util.concurrent.ThreadPoolExecutor;
1747 ThreadPoolExecutor executor) {}
/libcore/ojluni/src/test/java/util/concurrent/tck/
DThreadPoolExecutorTest.java66 import java.util.concurrent.ThreadPoolExecutor;
86 static class ExtendedTPE extends ThreadPoolExecutor {
128 final ThreadPoolExecutor p = in testExecute()
129 new ThreadPoolExecutor(1, 1, in testExecute()
148 final ThreadPoolExecutor p = in testGetActiveCount()
149 new ThreadPoolExecutor(2, 2, in testGetActiveCount()
171 final ThreadPoolExecutor p = in testPrestartCoreThread()
172 new ThreadPoolExecutor(2, 6, in testPrestartCoreThread()
198 final ThreadPoolExecutor p = in testPrestartAllCoreThreads()
199 new ThreadPoolExecutor(2, 6, in testPrestartAllCoreThreads()
[all …]
DThreadPoolExecutorSubclassTest.java65 import java.util.concurrent.ThreadPoolExecutor;
187 static class CustomTPE extends ThreadPoolExecutor {
274 final ThreadPoolExecutor p = in testExecute()
294 final ThreadPoolExecutor p = in testGetActiveCount()
317 final ThreadPoolExecutor p = in testPrestartCoreThread()
344 final ThreadPoolExecutor p = in testPrestartAllCoreThreads()
368 final ThreadPoolExecutor p = in testGetCompletedTaskCount()
402 final ThreadPoolExecutor p = in testGetCorePoolSize()
416 final ThreadPoolExecutor p = in testGetKeepAliveTime()
431 final ThreadPoolExecutor p = in testGetThreadFactory()
[all …]
DExecutorCompletionServiceTest.java57 import java.util.concurrent.ThreadPoolExecutor;
253 new ThreadPoolExecutor(1, 1, in testNewTaskForCallable()
284 new ThreadPoolExecutor(1, 1, in testNewTaskForRunnable()
DAbstractExecutorServiceTest.java61 import java.util.concurrent.ThreadPoolExecutor;
256 = new ThreadPoolExecutor(1,1,60, TimeUnit.SECONDS, in testInterruptedSubmit()
278 final ThreadPoolExecutor p = in testSubmitEE()
279 new ThreadPoolExecutor(1, 1, in testSubmitEE()
DScheduledExecutorTest.java69 import java.util.concurrent.ThreadPoolExecutor;
536 final ThreadPoolExecutor p = new ScheduledThreadPoolExecutor(2); in testGetCompletedTaskCount()
567 ThreadPoolExecutor p = new ScheduledThreadPoolExecutor(1); in testGetCorePoolSize()
580 final ThreadPoolExecutor p = new ScheduledThreadPoolExecutor(THREADS); in testGetLargestPoolSize()
604 final ThreadPoolExecutor p = new ScheduledThreadPoolExecutor(1); in testGetPoolSize()
628 final ThreadPoolExecutor p = new ScheduledThreadPoolExecutor(1); in testGetTaskCount()
717 final ThreadPoolExecutor p = new ScheduledThreadPoolExecutor(1); in testIsTerminated()
742 final ThreadPoolExecutor p = new ScheduledThreadPoolExecutor(1); in testIsTerminating()
DScheduledExecutorSubclassTest.java66 import java.util.concurrent.ThreadPoolExecutor;
449 final ThreadPoolExecutor p = new CustomExecutor(2); in testGetActiveCount()
470 final ThreadPoolExecutor p = new CustomExecutor(2); in testGetCompletedTaskCount()
515 final ThreadPoolExecutor p = new CustomExecutor(THREADS); in testGetLargestPoolSize()
539 final ThreadPoolExecutor p = new CustomExecutor(1); in testGetPoolSize()
562 final ThreadPoolExecutor p = new CustomExecutor(1); in testGetTaskCount()
649 final ThreadPoolExecutor p = new CustomExecutor(1); in testIsTerminated()
674 final ThreadPoolExecutor p = new CustomExecutor(1); in testIsTerminating()
DExecutorsTest.java60 import java.util.concurrent.ThreadPoolExecutor;
161 ThreadPoolExecutor tpe = (ThreadPoolExecutor)e; in testCastNewSingleThreadExecutor()
DJSR166TestCase.java127 import java.util.concurrent.ThreadPoolExecutor;
2164 ThreadPoolExecutor executor) {}
2332 new ThreadPoolExecutor(0, Integer.MAX_VALUE,
/libcore/ojluni/annotations/hiddenapi/java/util/concurrent/
DThreadPoolExecutor.java41 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/
DThreadPoolExecutorTest.java22 import java.util.concurrent.ThreadPoolExecutor;
29 ThreadPoolExecutor tp = new ThreadPoolExecutor( in testCorePoolSizeGreaterThanMax()
/libcore/ojluni/src/main/java/java/util/concurrent/
DThreadPoolExecutor.java333 public class ThreadPoolExecutor extends AbstractExecutorService { class
1204 public ThreadPoolExecutor(int corePoolSize, in ThreadPoolExecutor() method in ThreadPoolExecutor
1239 public ThreadPoolExecutor(int corePoolSize, in ThreadPoolExecutor() method in ThreadPoolExecutor
1275 public ThreadPoolExecutor(int corePoolSize, in ThreadPoolExecutor() method in ThreadPoolExecutor
1312 public ThreadPoolExecutor(int corePoolSize, in ThreadPoolExecutor() method in ThreadPoolExecutor
2070 public void rejectedExecution(Runnable r, ThreadPoolExecutor e) { in rejectedExecution()
2097 public void rejectedExecution(Runnable r, ThreadPoolExecutor e) { in rejectedExecution()
2120 public void rejectedExecution(Runnable r, ThreadPoolExecutor e) { in rejectedExecution()
2157 public void rejectedExecution(Runnable r, ThreadPoolExecutor e) { in rejectedExecution()
DExecutors.java99 return new ThreadPoolExecutor(nThreads, nThreads, in newFixedThreadPool()
162 return new ThreadPoolExecutor(nThreads, nThreads, in newFixedThreadPool()
199 (new ThreadPoolExecutor(1, 1, in newSingleThreadExecutor()
222 return new ThreadPoolExecutor(0, Integer.MAX_VALUE, in newCachedThreadPool()
238 return new ThreadPoolExecutor(0, Integer.MAX_VALUE, in newCachedThreadPool()
DRejectedExecutionHandler.java61 void rejectedExecution(Runnable r, ThreadPoolExecutor executor); in rejectedExecution()
DScheduledThreadPoolExecutor.java143 extends ThreadPoolExecutor
/libcore/ojluni/src/main/java/sun/nio/ch/
DThreadPool.java138 if (executor instanceof ThreadPoolExecutor) { in wrap()
139 int max = ((ThreadPoolExecutor)executor).getMaximumPoolSize(); in wrap()
/libcore/api/
Dcurrent.txt16432 method public void rejectedExecution(Runnable, java.util.concurrent.ThreadPoolExecutor);
16452 …public class ScheduledThreadPoolExecutor extends java.util.concurrent.ThreadPoolExecutor implement…
16549 public class ThreadPoolExecutor extends java.util.concurrent.AbstractExecutorService {
16550 …ctor public ThreadPoolExecutor(int, int, long, java.util.concurrent.TimeUnit, java.util.concurrent…
16551 …ctor public ThreadPoolExecutor(int, int, long, java.util.concurrent.TimeUnit, java.util.concurrent…
16552 …ctor public ThreadPoolExecutor(int, int, long, java.util.concurrent.TimeUnit, java.util.concurrent…
16553 …ctor public ThreadPoolExecutor(int, int, long, java.util.concurrent.TimeUnit, java.util.concurrent…
16589 …public static class ThreadPoolExecutor.AbortPolicy implements java.util.concurrent.RejectedExecuti…
16590 ctor public ThreadPoolExecutor.AbortPolicy();
16591 method public void rejectedExecution(Runnable, java.util.concurrent.ThreadPoolExecutor);
[all …]
/libcore/
Dopenjdk_java_files.bp1031 "ojluni/src/main/java/java/util/concurrent/ThreadPoolExecutor.java",

12