1 write to _occupiedNodes
System.Collections.Concurrent (1)
System\Collections\Concurrent\BlockingCollection.cs (1)
231_occupiedNodes = new SemaphoreSlim(collectionCount);
11 references to _occupiedNodes
System.Collections.Concurrent (11)
System\Collections\Concurrent\BlockingCollection.cs (11)
95return (IsAddingCompleted && (_occupiedNodes.CurrentCount == 0)); 108return _occupiedNodes.CurrentCount; 209[MemberNotNull(nameof(_occupiedNodes))] 485_occupiedNodes.Release(); 663waitForSemaphoreWasSuccessful = _occupiedNodes.Wait(0); 668waitForSemaphoreWasSuccessful = _occupiedNodes.Wait(millisecondsTimeout, linkedTokenSource.Token); 717_occupiedNodes.Release(); 1075handlesList.Add(collections[i]._occupiedNodes.AvailableWaitHandle); 1319if (!collections[i].IsCompleted && collections[i]._occupiedNodes.CurrentCount > 0 && collections[i].TryTake(out item)) 1405if (collections[i]._occupiedNodes.AvailableWaitHandle == handles[index]) 1505_occupiedNodes.Dispose();