C#教程之BlockingCollection使用|C#教程

当前位置:

首页 > 编程开发 > c#教程 >

C#教程之C#教程之BlockingCollection使用

本站最新发布 C#从入门到精通
试听地址 https://www.xin3721.com/eschool/CSharpxin3721/

BlockingCollection是一个线程安全的生产者-消费者集合。

代码

public class BlockingTest
    {
        BlockingCollection<int> bc = new BlockingCollection<int>();
        public BlockingTest()
        {
            Task.Factory.StartNew(ProduceTask);
            Task.Factory.StartNew(ConsumeTask);
        }

        private void ProduceTask()
        {
            foreach (var item in Enumerable.Range(1, 100))
            {
                Console.WriteLine(string.Format("+++++++++++++: {0}", item));
                bc.Add(item);
            }
            bc.CompleteAdding();
        }

        private void ConsumeTask()
        {
            foreach(var item in bc.GetConsumingEnumerable())
            {
                Console.WriteLine(string.Format("---------------: {0}", item));
            }
        }
    }

结果：

栏目列表

首页 > 编程开发 > c#教程 >

C#教程之C#教程之BlockingCollection使用