BlockingCollection使用

2016-12-30 11:27:19来源:cnblogs.com作者:疯子哥哥人点击

第七城市

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));            }        }    }

 

结果:

 

第七城市

最新文章

123

最新摄影

微信扫一扫

第七城市微信公众平台