Home
last modified time | relevance | path

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

12

/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()
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()
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()
DExecutorsTest.java52 import java.util.concurrent.ThreadPoolExecutor;
140 ThreadPoolExecutor tpe = (ThreadPoolExecutor)e; in testCastNewSingleThreadExecutor()
DJSR166TestCase.java118 import java.util.concurrent.ThreadPoolExecutor;
1857 ThreadPoolExecutor executor) {}
2031 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()
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()
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()
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/
DThreadPoolExecutor.java327 public class ThreadPoolExecutor extends AbstractExecutorService { class
1183 public ThreadPoolExecutor(int corePoolSize, in ThreadPoolExecutor() method in ThreadPoolExecutor
1218 public ThreadPoolExecutor(int corePoolSize, in ThreadPoolExecutor() method in ThreadPoolExecutor
1254 public ThreadPoolExecutor(int corePoolSize, in ThreadPoolExecutor() method in ThreadPoolExecutor
1291 public ThreadPoolExecutor(int corePoolSize, in ThreadPoolExecutor() method in ThreadPoolExecutor
2042 public void rejectedExecution(Runnable r, ThreadPoolExecutor e) { in rejectedExecution()
2069 public void rejectedExecution(Runnable r, ThreadPoolExecutor e) { in rejectedExecution()
2092 public void rejectedExecution(Runnable r, ThreadPoolExecutor e) { in rejectedExecution()
2116 public void rejectedExecution(Runnable r, ThreadPoolExecutor e) { in rejectedExecution()
DExecutors.java97 return new ThreadPoolExecutor(nThreads, nThreads, in newFixedThreadPool()
160 return new ThreadPoolExecutor(nThreads, nThreads, in newFixedThreadPool()
181 (new ThreadPoolExecutor(1, 1, in newSingleThreadExecutor()
200 (new ThreadPoolExecutor(1, 1, in newSingleThreadExecutor()
223 return new ThreadPoolExecutor(0, Integer.MAX_VALUE, in newCachedThreadPool()
239 return new ThreadPoolExecutor(0, Integer.MAX_VALUE, in newCachedThreadPool()
DRejectedExecutionHandler.java61 void rejectedExecution(Runnable r, ThreadPoolExecutor executor); in rejectedExecution()
DScheduledThreadPoolExecutor.java137 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.txt15312 method public void rejectedExecution(Runnable, java.util.concurrent.ThreadPoolExecutor);
15332 …public class ScheduledThreadPoolExecutor extends java.util.concurrent.ThreadPoolExecutor implement…
15426 public class ThreadPoolExecutor extends java.util.concurrent.AbstractExecutorService {
15427 …ctor public ThreadPoolExecutor(int, int, long, java.util.concurrent.TimeUnit, java.util.concurrent…
15428 …ctor public ThreadPoolExecutor(int, int, long, java.util.concurrent.TimeUnit, java.util.concurrent…
15429 …ctor public ThreadPoolExecutor(int, int, long, java.util.concurrent.TimeUnit, java.util.concurrent…
15430 …ctor public ThreadPoolExecutor(int, int, long, java.util.concurrent.TimeUnit, java.util.concurrent…
15466 …public static class ThreadPoolExecutor.AbortPolicy implements java.util.concurrent.RejectedExecuti…
15467 ctor public ThreadPoolExecutor.AbortPolicy();
15468 method public void rejectedExecution(Runnable, java.util.concurrent.ThreadPoolExecutor);
[all …]
/libcore/
Dopenjdk_java_files.bp1002 "ojluni/src/main/java/java/util/concurrent/ThreadPoolExecutor.java",

12