| /libcore/ojluni/src/main/java/java/util/concurrent/ |
| D | ThreadPoolExecutor.java | 459 private final BlockingQueue<Runnable> workQueue; field in ThreadPoolExecutor
722 (runStateLessThan(c, STOP) && ! workQueue.isEmpty())) in tryTerminate()
860 BlockingQueue<Runnable> q = workQueue; in drainQueue()
909 || workQueue.isEmpty())) in addWorker()
1017 if (min == 0 && ! workQueue.isEmpty()) in processWorkerExit()
1051 && (runStateAtLeast(c, STOP) || workQueue.isEmpty())) { in getTask()
1062 && (wc > 1 || workQueue.isEmpty())) { in getTask()
1070 workQueue.poll(keepAliveTime, TimeUnit.NANOSECONDS) : in getTask()
1071 workQueue.take(); in getTask()
1197 BlockingQueue<Runnable> workQueue) { in ThreadPoolExecutor() argument
[all …]
|
| D | ForkJoinWorkerThread.java | 67 final ForkJoinPool.WorkQueue workQueue; // work-stealing mechanics field in ForkJoinWorkerThread
76 this.workQueue = new ForkJoinPool.WorkQueue(this, isInnocuous); in ForkJoinWorkerThread()
126 return workQueue.getPoolIndex(); in getPoolIndex()
160 ForkJoinPool.WorkQueue w = workQueue; in run()
|
| D | ForkJoinTask.java | 410 q = wt.workQueue; in awaitDone()
654 (w = (ForkJoinWorkerThread)t).workQueue.push(this, w.pool); in fork()
1075 p.helpQuiescePool(w.workQueue, Long.MAX_VALUE, false); in helpQuiesce()
1141 ? (q = ((ForkJoinWorkerThread)t).workQueue) != null in tryUnfork()
1158 q = ((ForkJoinWorkerThread)t).workQueue; in getQueuedTaskCount()
1233 q = ((ForkJoinWorkerThread)t).workQueue; in peekNextLocalTask()
1251 ((ForkJoinWorkerThread)t).workQueue.nextLocalTask() : null); in pollNextLocalTask()
1270 (w = (ForkJoinWorkerThread)t).pool.nextTaskFor(w.workQueue) : in pollTask()
|
| D | CountedCompleter.java | 728 q = ((ForkJoinWorkerThread)t).workQueue; in helpComplete()
|
| D | ForkJoinPool.java | 1551 if (wt != null && (w = wt.workQueue) != null && lock != null) {
2195 (q = (wt = (ForkJoinWorkerThread)t).workQueue) != null &&
2235 w = wt.workQueue;
2289 (q = wt.workQueue) != null) {
3285 q = helpQuiescePool(wt.workQueue, nanos, true);
3322 q = helpQuiescePool(wt.workQueue, nanos, false);
|
| /libcore/ojluni/annotations/hiddenapi/java/util/concurrent/ |
| D | ThreadPoolExecutor.java | 48 java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue) { in ThreadPoolExecutor() argument
57 java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue, in ThreadPoolExecutor() argument
67 java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue, in ThreadPoolExecutor() argument
77 java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue, in ThreadPoolExecutor() argument
387 private final java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue; field in ThreadPoolExecutor
390 workQueue = null;
|
| /libcore/jsr166-tests/src/test/java/jsr166/ |
| D | ThreadPoolExecutorSubclassTest.java | 164 BlockingQueue<Runnable> workQueue) { in CustomTPE() argument
166 workQueue); in CustomTPE()
172 BlockingQueue<Runnable> workQueue, in CustomTPE() argument
174 super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, in CustomTPE()
182 BlockingQueue<Runnable> workQueue, in CustomTPE() argument
184 super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, in CustomTPE()
191 BlockingQueue<Runnable> workQueue, in CustomTPE() argument
195 workQueue, threadFactory, handler); in CustomTPE()
|
| /libcore/ojluni/src/test/java/util/concurrent/tck/ |
| D | ThreadPoolExecutorSubclassTest.java | 186 BlockingQueue<Runnable> workQueue) { in CustomTPE() argument
188 workQueue); in CustomTPE()
194 BlockingQueue<Runnable> workQueue, in CustomTPE() argument
196 super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, in CustomTPE()
204 BlockingQueue<Runnable> workQueue, in CustomTPE() argument
206 super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, in CustomTPE()
213 BlockingQueue<Runnable> workQueue, in CustomTPE() argument
217 workQueue, threadFactory, handler); in CustomTPE()
|