| /libcore/ojluni/src/main/java/java/util/concurrent/ |
| D | ThreadPoolExecutor.java | 466 private final BlockingQueue<Runnable> workQueue; field in ThreadPoolExecutor
719 (runStateOf(c) == SHUTDOWN && ! workQueue.isEmpty())) in tryTerminate()
877 BlockingQueue<Runnable> q = workQueue; in drainQueue()
929 ! workQueue.isEmpty())) in addWorker()
1038 if (min == 0 && ! workQueue.isEmpty()) in processWorkerExit()
1072 if (rs >= SHUTDOWN && (rs >= STOP || workQueue.isEmpty())) { in getTask()
1083 && (wc > 1 || workQueue.isEmpty())) { in getTask()
1091 workQueue.poll(keepAliveTime, TimeUnit.NANOSECONDS) : in getTask()
1092 workQueue.take(); in getTask()
1219 BlockingQueue<Runnable> workQueue) { in ThreadPoolExecutor() argument
[all …]
|
| D | ForkJoinWorkerThread.java | 74 final ForkJoinPool.WorkQueue workQueue; // work-stealing mechanics field in ForkJoinWorkerThread
86 this.workQueue = pool.registerWorker(this); in ForkJoinWorkerThread()
98 this.workQueue = pool.registerWorker(this); in ForkJoinWorkerThread()
121 return workQueue.getPoolIndex(); in getPoolIndex()
153 if (workQueue.array == null) { // only run once in run()
157 pool.runWorker(workQueue); in run()
|
| D | ForkJoinTask.java | 384 (w = (wt = (ForkJoinWorkerThread)t).workQueue). in doJoin()
400 awaitJoin(wt.workQueue, this, 0L) : in doInvoke()
692 ((ForkJoinWorkerThread)t).workQueue.push(this); in fork()
1027 s = wt.pool.awaitJoin(wt.workQueue, this, deadline); in get()
1091 wt.pool.helpQuiescePool(wt.workQueue); in helpQuiesce()
1160 ((ForkJoinWorkerThread)t).workQueue.tryUnpush(this) : in tryUnfork()
1175 q = ((ForkJoinWorkerThread)t).workQueue; in getQueuedTaskCount()
1251 q = ((ForkJoinWorkerThread)t).workQueue; in peekNextLocalTask()
1269 ((ForkJoinWorkerThread)t).workQueue.nextLocalTask() : in pollNextLocalTask()
1289 (wt = (ForkJoinWorkerThread)t).pool.nextTaskFor(wt.workQueue) : in pollTask()
|
| D | CountedCompleter.java | 711 helpComplete(wt.workQueue, this, maxTasks); in helpComplete()
|
| D | ForkJoinPool.java | 1550 if (isSpare && (q = wt.workQueue) != null) in createWorker()
1639 if (wt != null && (w = wt.workQueue) != null) { in deregisterWorker()
2391 int n = (q = wt.workQueue).top - q.base; in getSurplusQueuedTaskCount()
2563 (q = w.workQueue) != null) in externalSubmit()
3287 helpQuiescePool(wt.workQueue); in awaitQuiescence()
3431 WorkQueue w = wt.workQueue; in managedBlock()
|
| /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/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()
|
| /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()
|