Home
last modified time | relevance | path

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

/libcore/ojluni/src/test/java/util/concurrent/tck/
DThreadPoolExecutorTest.java58 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 …]
DThreadPoolExecutorSubclassTest.java57 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 …]
DExecutorCompletionServiceTest.java49 import java.util.concurrent.ThreadPoolExecutor;
229 new ThreadPoolExecutor(1, 1, in testNewTaskForCallable()
259 new ThreadPoolExecutor(1, 1, in testNewTaskForRunnable()
DAbstractExecutorServiceTest.java53 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()
DScheduledExecutorSubclassTest.java56 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()
DScheduledExecutorTest.java55 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()
DExecutorsTest.java52 import java.util.concurrent.ThreadPoolExecutor;
140 ThreadPoolExecutor tpe = (ThreadPoolExecutor)e; in testCastNewSingleThreadExecutor()
DJSR166TestCase.java118 import java.util.concurrent.ThreadPoolExecutor;
1856 ThreadPoolExecutor executor) {}
2030 new ThreadPoolExecutor(0, Integer.MAX_VALUE,
/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/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/
DExecutors.java96 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()
DThreadPoolExecutor.java339 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()
DRejectedExecutionHandler.java61 void rejectedExecution(Runnable r, ThreadPoolExecutor executor); in rejectedExecution()
DScheduledThreadPoolExecutor.java131 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.txt14946 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/
Dopenjdk_java_files.bp985 "ojluni/src/main/java/java/util/concurrent/ThreadPoolExecutor.java",