Home
last modified time | relevance | path

Searched refs:ctl (Results 1 – 3 of 3) sorted by relevance

/libcore/luni/src/main/java/java/util/concurrent/
DThreadPoolExecutor.java347 private final AtomicInteger ctl = new AtomicInteger(ctlOf(RUNNING, 0)); field in ThreadPoolExecutor
384 return ctl.compareAndSet(expect, expect + 1); in compareAndIncrementWorkerCount()
391 return ctl.compareAndSet(expect, expect - 1); in compareAndDecrementWorkerCount()
400 do {} while (! compareAndDecrementWorkerCount(ctl.get())); in decrementWorkerCount()
642 int c = ctl.get(); in advanceRunState()
644 ctl.compareAndSet(c, ctlOf(targetState, workerCountOf(c)))) in advanceRunState()
661 int c = ctl.get(); in tryTerminate()
674 if (ctl.compareAndSet(c, ctlOf(TIDYING, 0))) { in tryTerminate()
678 ctl.set(ctlOf(TERMINATED, 0)); in tryTerminate()
811 int rs = runStateOf(ctl.get()); in isRunningOrShutdown()
[all …]
DForkJoinPool.java1228 volatile long ctl; // main pool control field in ForkJoinPool
1293 while ((u = (int)((c = ctl) >>> 32)) < 0 && in tryAddWorker()
1402 (this, CTL, c = ctl, (((c - AC_UNIT) & AC_MASK) | in deregisterWorker()
1409 while ((u = (int)((c = ctl) >>> 32)) < 0 && (e = (int)c) >= 0) { in deregisterWorker()
1591 (this, CTL, c = ctl, ((c & ~AC_MASK) | in incrementActiveCount()
1604 if ((u = (int)((c = ctl) >>> 32)) >= 0) in signalWork()
1665 long c = ctl; // for consistency check in scan()
1689 else if (ctl == c) { // try to inactivate and enqueue in scan()
1719 if ((stat = w.qlock) >= 0 && w.eventCount == ec && ctl == c && in awaitWork()
1745 if (w.eventCount == ec && ctl == c) { in awaitWork()
[all …]
DForkJoinTask.java1016 if (p == null || p.tryCompensate(p.ctl)) in get()