Initialize()

void System.Collections.Concurrent.BlockingCollection< T >.Initialize ( IProducerConsumerCollection< T > collection, int boundedCapacity, int collectionCount )

inlineprivate

Definition at line 129 of file BlockingCollection.cs.

    {
        _collection = collection;
        _boundedCapacity = boundedCapacity;
        _isDisposed = false;
        _consumersCancellationTokenSource = new CancellationTokenSource();
        _producersCancellationTokenSource = new CancellationTokenSource();
        if (boundedCapacity == -1)
        {
            _freeNodes = null;
        }
        else
        {
            _freeNodes = new SemaphoreSlim(boundedCapacity - collectionCount);
        }
        _occupiedNodes = new SemaphoreSlim(collectionCount);
    }

References System.Collections.Concurrent.BlockingCollection< T >._boundedCapacity, System.Collections.Concurrent.BlockingCollection< T >._collection, System.Collections.Concurrent.BlockingCollection< T >._consumersCancellationTokenSource, System.Collections.Concurrent.BlockingCollection< T >._freeNodes, System.Collections.Concurrent.BlockingCollection< T >._isDisposed, System.Collections.Concurrent.BlockingCollection< T >._occupiedNodes, System.Collections.Concurrent.BlockingCollection< T >._producersCancellationTokenSource, and System.collection.

Referenced by System.Collections.Concurrent.BlockingCollection< T >.BlockingCollection(), and System.Collections.Concurrent.BlockingCollection< T >.BlockingCollection().