ValidateCollectionsArray()

static void System.Collections.Concurrent.BlockingCollection< T >.ValidateCollectionsArray ( BlockingCollection< T >[] collections, bool isAddOperation )

inlinestaticprivate

Definition at line 770 of file BlockingCollection.cs.

    {
        if (collections == null)
        {
            throw new ArgumentNullException("collections");
        }
        if (collections.Length < 1)
        {
            throw new ArgumentException(System.SR.BlockingCollection_ValidateCollectionsArray_ZeroSize, "collections");
        }
        if (collections.Length > 63 || (collections.Length == 63 && Thread.CurrentThread.GetApartmentState() == ApartmentState.STA))
        {
            throw new ArgumentOutOfRangeException("collections", System.SR.BlockingCollection_ValidateCollectionsArray_LargeSize);
        }
        for (int i = 0; i < collections.Length; i++)
        {
            if (collections[i] == null)
            {
                throw new ArgumentException(System.SR.BlockingCollection_ValidateCollectionsArray_NullElems, "collections");
            }
            if (collections[i]._isDisposed)
            {
                throw new ObjectDisposedException("collections", System.SR.BlockingCollection_ValidateCollectionsArray_DispElems);
            }
            if (isAddOperation && collections[i].IsAddingCompleted)
            {
                throw new ArgumentException(System.SR.BlockingCollection_CantAddAnyWhenCompleted, "collections");
            }
        }
    }

References System.Collections.Concurrent.BlockingCollection< T >._isDisposed, System.SR.BlockingCollection_CantAddAnyWhenCompleted, System.SR.BlockingCollection_ValidateCollectionsArray_DispElems, System.SR.BlockingCollection_ValidateCollectionsArray_LargeSize, System.SR.BlockingCollection_ValidateCollectionsArray_NullElems, System.SR.BlockingCollection_ValidateCollectionsArray_ZeroSize, System.Threading.Thread.CurrentThread, and System.Collections.Concurrent.BlockingCollection< T >.IsAddingCompleted.

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