Searched refs:parallelism (Results 1 – 2 of 2) sorted by relevance
1231 final short parallelism; // parallelism level field in ForkJoinPool1528 int p = parallelism; // find power of two table size in fullExternalPush()1723 int d = (u >> UAC_SHIFT) + parallelism; // active count in awaitWork()1930 int pc = parallelism, e = (int)c, m, tc; in tryCompensate()2095 if ((int)(nc >> AC_SHIFT) + parallelism == 0) in helpQuiescePool()2100 else if ((int)((c = ctl) >> AC_SHIFT) + parallelism <= 0 && in helpQuiescePool()2174 int p = (pool = (wt = (ForkJoinWorkerThread)t).pool).parallelism; in getSurplusQueuedTaskCount()2218 if ((short)(c >>> TC_SHIFT) + parallelism <= 0) { in tryTerminate()2227 if ((int)(c >> AC_SHIFT) + parallelism > 0) in tryTerminate()2380 public ForkJoinPool(int parallelism) { in ForkJoinPool() argument[all …]
82 public static ExecutorService newWorkStealingPool(int parallelism) { in newWorkStealingPool() argument84 (parallelism, in newWorkStealingPool()