c# blockingcollections

    class Program
    {
        static BlockingCollection<int> cols = new BlockingCollection<int>(2); //设置阻塞队列最大的容量；
        public static void Main(string[] args)
        {
        
            
            var t1 = Task.Factory.StartNew(product);
            
            Thread.Sleep(50);
            t1.Wait();
            Task.Factory.StartNew(consumer);
            
            
            
            Console.ReadKey(true);
        }
        public static void product(){
            
            for (int i = 0; i < 2; i++) {
                
                cols.Add(i);
                Console.WriteLine("i`m producter set value{0}", i);
            }
            
            Console.WriteLine("all item has add...");
            //cols.CompleteAdding(); //设置完成标志位，否则 IsAddingCompleted一直是true
            
        }
        
        public static void consumer(){
            
            
            while (!cols.IsAddingCompleted) {
                
                
                Console.WriteLine("take function is 阻塞的么？");
                int item;
                bool finish = cols.TryTake(out item,  TimeSpan.FromSeconds(5));// try可以加阻塞时间，超时则停止取值；
                
                if(finish){
                    
                    Console.WriteLine("i`m consumer get value {0}", item);
                }
                
            }
            
            Console.WriteLine("all item has get...");
        }
    }