29 references to counts
System.Private.CoreLib (29)
src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\PortableThreadPool.Blocking.cs (6)
15return Math.Min(_separated.counts.NumThreadsGoal, TargetThreadsGoalForBlockingAdjustment); 47_separated.counts.NumThreadsGoal < TargetThreadsGoalForBlockingAdjustment) 82_separated.counts.NumThreadsGoal > TargetThreadsGoalForBlockingAdjustment) 129ThreadCounts counts = _separated.counts; 149_separated.counts.InterlockedSetNumThreadsGoal(numThreadsGoal); 229counts = _separated.counts.InterlockedSetNumThreadsGoal(newNumThreadsGoal);
src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\PortableThreadPool.cs (10)
165_separated.counts.NumThreadsGoal = _minThreads; 223else if (_separated.counts.NumThreadsGoal < newMinThreads) 225_separated.counts.InterlockedSetNumThreadsGoal(newMinThreads); 297if (_separated.counts.NumThreadsGoal > newMaxThreads) 299_separated.counts.InterlockedSetNumThreadsGoal(newMaxThreads); 326ThreadCounts counts = _separated.counts.VolatileRead(); 331public int ThreadCount => _separated.counts.VolatileRead().NumExistingThreads; 390ThreadCounts counts = _separated.counts; 412_separated.counts.InterlockedSetNumThreadsGoal((short)newNumThreadsGoal); 469ThreadCounts counts = _separated.counts;
src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\PortableThreadPool.GateThread.cs (3)
151ThreadCounts counts = threadPoolInstance._separated.counts; 166threadPoolInstance._separated.counts.InterlockedCompareExchange(newCounts, counts); 219minimumDelay = (uint)threadPoolInstance._separated.counts.NumThreadsGoal * DequeueDelayThresholdMs;
src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\PortableThreadPool.WorkerThread.cs (10)
49(uint)ThreadPoolInstance._separated.counts.VolatileRead().NumExistingThreads); 73(uint)threadPoolInstance._separated.counts.VolatileRead().NumExistingThreads); 190ThreadCounts counts = threadPoolInstance._separated.counts; 211threadPoolInstance._separated.counts.InterlockedCompareExchange(newCounts, counts); 244ThreadCounts oldCounts = threadPoolInstance._separated.counts; 247if (threadPoolInstance._separated.counts.InterlockedCompareExchange(newCounts, oldCounts) == oldCounts) 268oldCounts = threadPoolInstance._separated.counts; 272if (threadPoolInstance._separated.counts.InterlockedCompareExchange(newCounts, oldCounts) == oldCounts) 306ThreadCounts counts = threadPoolInstance._separated.counts; 321ThreadCounts oldCounts = threadPoolInstance._separated.counts.InterlockedCompareExchange(newCounts, counts);