1 write to m_occupiedNodes
System (1)
sys\system\collections\concurrent\BlockingCollection.cs (1)
247m_occupiedNodes = new SemaphoreSlim(collectionCount);
10 references to m_occupiedNodes
System (10)
sys\system\collections\concurrent\BlockingCollection.cs (10)
106return (IsAddingCompleted && (m_occupiedNodes.CurrentCount == 0)); 119return m_occupiedNodes.CurrentCount; 520m_occupiedNodes.Release(); 705waitForSemaphoreWasSuccessful = m_occupiedNodes.Wait(0); 712waitForSemaphoreWasSuccessful = m_occupiedNodes.Wait(millisecondsTimeout, linkedTokenSource.Token); 765m_occupiedNodes.Release(); 1125handlesList.Add(collections[i].m_occupiedNodes.AvailableWaitHandle); 1371if (!collections[i].IsCompleted && collections[i].m_occupiedNodes.CurrentCount > 0 && collections[i].TryTake(out item)) 1458if (collections[i].m_occupiedNodes.AvailableWaitHandle == handles[index]) 1563m_occupiedNodes.Dispose();