VB.net 2010 视频教程 VB.net 2010 视频教程 VB.net 2010 视频教程
SQL Server 2008 视频教程 c#入门经典教程 Visual Basic从门到精通视频教程
当前位置:
首页 > 编程开发 > c#教程 >
  • C#教程之BlockingCollection使用

  • 2018-12-22 22:32 来源:未知

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));
            }
        }
    }
复制代码

 

结果:

 

相关教程