Tag: 阻塞收集

我们有什么比BlockingCollection更好的异步执行方法？

我写了这样的例子来衡量BlockingCollection的异步执行速度 using System; using System.Collections.Concurrent; using System.Diagnostics; using System.Threading; using System.Threading.Tasks; namespace TestBlockingCollection { class Program { static void Main(string[] args) { BlockingCollection blockingCollection = new BlockingCollection(); Stopwatch sw = Stopwatch.StartNew(); Task.Factory.StartNew(() => { int i = 0; while (true) { Console.WriteLine(“Adding ” + i); sw = Stopwatch.StartNew(); blockingCollection.Add(i++); Thread.Sleep(1000); } }); Task.Factory.StartNew(() => { […]