// Check if the collection is not completed, and potentially has at least one element by checking the semaphore count
    if (!collections[i].IsCompleted && collections[i]._occupiedNodes.CurrentCount > 0 && **collections[i].TryTake(out item))**

      public bool TryTake([MaybeNullWhen(false)] out T item)
        {
            return TryTake(out item, 0, **CancellationToken.None**);
        }

    internal class Program
    {
        static void Main(string[] args)
        {
            int value = 0;
            CancellationTokenSource cts = new CancellationTokenSource(5000);
            BlockingCollection<int> collection = new BlockingCollection<int>(new ConcurrentStack<int>(), 10);
            BlockingCollection<int> priority = new BlockingCollection<int>(new ConcurrentStack<int>(), 3);
            BlockingCollection<int>[] list = new BlockingCollection<int>[] { priority, collection };
            var producer = Task.Run(() =>
            {
                try
                {
                    while (value < 20)
                    {
                        collection.Add(value++, cts.Token);
                        Console.WriteLine("+++added.");
                        Task.Delay(500).Wait();
                    }
                }
                catch(OperationCanceledException)
                {
                    Console.WriteLine("Canceled");
                }
                
            });
            var producer2 = Task.Run(() =>
            {
                Task.Delay(2500).Wait();
                try
                {
                    while (value < 20)
                    {
                        priority.Add(value++ + 100, cts.Token);
                        Console.WriteLine("+++added pr.");
                        Task.Delay(500).Wait();
                    }
                }
                catch (OperationCanceledException)
                {
                    Console.WriteLine("Canceled");
                }

            });
            var consumer = Task.Run(() =>
            {
                try
                {
                    while (true)
                    {
                        //cts.Token.ThrowIfCancellationRequested();   recomment here for immediate cancel
                        _ = BlockingCollection<int>.TakeFromAny(list, out int val, cts.Token);
                        Console.WriteLine("---taked " + val.ToString());
                        Task.Delay(1000).Wait();
                    }
                }
                catch (OperationCanceledException)
                {
                    Console.WriteLine("Canceled");
                }
            });
            Console.ReadLine();
    }
}