| /libcore/ojluni/src/main/java/java/util/concurrent/ |
| D | ThreadPoolExecutor.java | 555 private volatile int corePoolSize; field in ThreadPoolExecutor
914 >= ((core ? corePoolSize : maximumPoolSize) & COUNT_MASK)) in addWorker()
1016 int min = allowCoreThreadTimeOut ? 0 : corePoolSize; in processWorkerExit()
1059 boolean timed = allowCoreThreadTimeOut || wc > corePoolSize; in getTask()
1193 public ThreadPoolExecutor(int corePoolSize, in ThreadPoolExecutor() argument
1198 this(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, in ThreadPoolExecutor()
1228 public ThreadPoolExecutor(int corePoolSize, in ThreadPoolExecutor() argument
1234 this(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, in ThreadPoolExecutor()
1264 public ThreadPoolExecutor(int corePoolSize, in ThreadPoolExecutor() argument
1270 this(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, in ThreadPoolExecutor()
[all …]
|
| D | ScheduledThreadPoolExecutor.java | 460 public ScheduledThreadPoolExecutor(int corePoolSize) { in ScheduledThreadPoolExecutor() argument
461 super(corePoolSize, Integer.MAX_VALUE, in ScheduledThreadPoolExecutor()
477 public ScheduledThreadPoolExecutor(int corePoolSize, in ScheduledThreadPoolExecutor() argument
479 super(corePoolSize, Integer.MAX_VALUE, in ScheduledThreadPoolExecutor()
495 public ScheduledThreadPoolExecutor(int corePoolSize, in ScheduledThreadPoolExecutor() argument
497 super(corePoolSize, Integer.MAX_VALUE, in ScheduledThreadPoolExecutor()
516 public ScheduledThreadPoolExecutor(int corePoolSize, in ScheduledThreadPoolExecutor() argument
519 super(corePoolSize, Integer.MAX_VALUE, in ScheduledThreadPoolExecutor()
|
| D | Executors.java | 293 public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize) { in newScheduledThreadPool() argument
294 return new ScheduledThreadPoolExecutor(corePoolSize); in newScheduledThreadPool()
309 int corePoolSize, ThreadFactory threadFactory) { in newScheduledThreadPool() argument
310 return new ScheduledThreadPoolExecutor(corePoolSize, threadFactory); in newScheduledThreadPool()
|
| D | ForkJoinPool.java | 2522 int corePoolSize,
2539 int corep = Math.min(Math.max(corePoolSize, p), MAX_CAP);
|
| /libcore/ojluni/annotations/hiddenapi/java/util/concurrent/ |
| D | ThreadPoolExecutor.java | 44 int corePoolSize, in ThreadPoolExecutor() argument
53 int corePoolSize, in ThreadPoolExecutor() argument
63 int corePoolSize, in ThreadPoolExecutor() argument
73 int corePoolSize, in ThreadPoolExecutor() argument
229 public void setCorePoolSize(int corePoolSize) { in setCorePoolSize() argument
342 private volatile int corePoolSize; field in ThreadPoolExecutor
|
| D | Executors.java | 92 int corePoolSize) { in newScheduledThreadPool() argument
97 int corePoolSize, java.util.concurrent.ThreadFactory threadFactory) { in newScheduledThreadPool() argument
|
| /libcore/jsr166-tests/src/test/java/jsr166/ |
| D | ScheduledExecutorSubclassTest.java | 91 CustomExecutor(int corePoolSize) { super(corePoolSize); } in CustomExecutor() argument
92 CustomExecutor(int corePoolSize, RejectedExecutionHandler handler) { in CustomExecutor() argument
93 super(corePoolSize, handler); in CustomExecutor()
96 CustomExecutor(int corePoolSize, ThreadFactory threadFactory) { in CustomExecutor() argument
97 super(corePoolSize, threadFactory); in CustomExecutor()
99 CustomExecutor(int corePoolSize, ThreadFactory threadFactory, in CustomExecutor() argument
101 super(corePoolSize, threadFactory, handler); in CustomExecutor()
|
| D | ThreadPoolExecutorSubclassTest.java | 160 CustomTPE(int corePoolSize, in CustomTPE() argument
165 super(corePoolSize, maximumPoolSize, keepAliveTime, unit, in CustomTPE()
168 CustomTPE(int corePoolSize, in CustomTPE() argument
174 super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, in CustomTPE()
178 CustomTPE(int corePoolSize, in CustomTPE() argument
184 super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, in CustomTPE()
187 CustomTPE(int corePoolSize, in CustomTPE() argument
194 super(corePoolSize, maximumPoolSize, keepAliveTime, unit, in CustomTPE()
|
| /libcore/ojluni/src/test/java/util/concurrent/tck/ |
| D | ScheduledExecutorSubclassTest.java | 115 CustomExecutor(int corePoolSize) { super(corePoolSize); } in CustomExecutor() argument
116 CustomExecutor(int corePoolSize, RejectedExecutionHandler handler) { in CustomExecutor() argument
117 super(corePoolSize, handler); in CustomExecutor()
120 CustomExecutor(int corePoolSize, ThreadFactory threadFactory) { in CustomExecutor() argument
121 super(corePoolSize, threadFactory); in CustomExecutor()
123 CustomExecutor(int corePoolSize, ThreadFactory threadFactory, in CustomExecutor() argument
125 super(corePoolSize, threadFactory, handler); in CustomExecutor()
|
| D | ThreadPoolExecutorSubclassTest.java | 182 CustomTPE(int corePoolSize, in CustomTPE() argument
187 super(corePoolSize, maximumPoolSize, keepAliveTime, unit, in CustomTPE()
190 CustomTPE(int corePoolSize, in CustomTPE() argument
196 super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, in CustomTPE()
200 CustomTPE(int corePoolSize, in CustomTPE() argument
206 super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, in CustomTPE()
209 CustomTPE(int corePoolSize, in CustomTPE() argument
216 super(corePoolSize, maximumPoolSize, keepAliveTime, unit, in CustomTPE()
|