Searched refs:ctl (Results 1 – 2 of 2) sorted by relevance
| /libcore/luni/src/main/java/java/util/concurrent/ |
| D | ThreadPoolExecutor.java | 367 private final AtomicInteger ctl = new AtomicInteger(ctlOf(RUNNING, 0)); field in ThreadPoolExecutor
404 return ctl.compareAndSet(expect, expect + 1); in compareAndIncrementWorkerCount()
411 return ctl.compareAndSet(expect, expect - 1); in compareAndDecrementWorkerCount()
420 do {} while (! compareAndDecrementWorkerCount(ctl.get())); in decrementWorkerCount()
663 int c = ctl.get(); in advanceRunState()
665 ctl.compareAndSet(c, ctlOf(targetState, workerCountOf(c)))) in advanceRunState()
682 int c = ctl.get(); in tryTerminate()
695 if (ctl.compareAndSet(c, ctlOf(TIDYING, 0))) { in tryTerminate()
699 ctl.set(ctlOf(TERMINATED, 0)); in tryTerminate()
832 int rs = runStateOf(ctl.get()); in isRunningOrShutdown()
[all …]
|
| D | ForkJoinPool.java | 1461 volatile long ctl; // main pool control field in ForkJoinPool
1542 if (ctl == c && U.compareAndSwapLong(this, CTL, c, nc)) { in tryAddWorker()
1546 } while (((c = ctl) & ADD_WORKER) != 0L && (int)c == 0); in tryAddWorker()
1626 (this, CTL, c = ctl, ((AC_MASK & (c - AC_UNIT)) | in deregisterWorker()
1640 else if ((sp = (int)(c = ctl)) != 0) { // wake up replacement in deregisterWorker()
1665 if ((c = ctl) >= 0L) // enough workers in signalWork()
1726 if ((sp = (int)(c = ctl)) != 0 && w != null && in tryReactivate()
1753 nc = lc | (UC_MASK & ((c = ctl) - AC_UNIT)); in inactivate()
1771 long c = ctl; in awaitWork()
1815 (int)c == ss && (aux = auxState) != null && ctl == c && in timedAwaitWork()
[all …]
|