Home
last modified time | relevance | path

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

/libcore/ojluni/src/main/java/java/util/concurrent/
DThreadPoolExecutor.java399 private final AtomicInteger ctl = new AtomicInteger(ctlOf(RUNNING, 0)); field in ThreadPoolExecutor
436 return ctl.compareAndSet(expect, expect + 1); in compareAndIncrementWorkerCount()
443 return ctl.compareAndSet(expect, expect - 1); in compareAndDecrementWorkerCount()
452 do {} while (! compareAndDecrementWorkerCount(ctl.get())); in decrementWorkerCount()
697 int c = ctl.get(); in advanceRunState()
699 ctl.compareAndSet(c, ctlOf(targetState, workerCountOf(c)))) in advanceRunState()
716 int c = ctl.get(); in tryTerminate()
729 if (ctl.compareAndSet(c, ctlOf(TIDYING, 0))) { in tryTerminate()
733 ctl.set(ctlOf(TERMINATED, 0)); in tryTerminate()
866 int rs = runStateOf(ctl.get()); in isRunningOrShutdown()
[all …]
DForkJoinPool.java1493 volatile long ctl; // main pool control field in ForkJoinPool
1574 if (ctl == c && U.compareAndSwapLong(this, CTL, c, nc)) { in tryAddWorker()
1578 } while (((c = ctl) & ADD_WORKER) != 0L && (int)c == 0); in tryAddWorker()
1658 (this, CTL, c = ctl, ((AC_MASK & (c - AC_UNIT)) | in deregisterWorker()
1672 else if ((sp = (int)(c = ctl)) != 0) { // wake up replacement in deregisterWorker()
1697 if ((c = ctl) >= 0L) // enough workers in signalWork()
1758 if ((sp = (int)(c = ctl)) != 0 && w != null && in tryReactivate()
1785 nc = lc | (UC_MASK & ((c = ctl) - AC_UNIT)); in inactivate()
1803 long c = ctl; in awaitWork()
1847 (int)c == ss && (aux = auxState) != null && ctl == c && in timedAwaitWork()
[all …]
/libcore/ojluni/annotations/hiddenapi/java/util/concurrent/
DThreadPoolExecutor.java345 private final java.util.concurrent.atomic.AtomicInteger ctl; field in ThreadPoolExecutor
348 ctl = null;