class Program { static ConcurrentQueue<int> _queue = new ConcurrentQueue<int>(); static List<int> list = new List<int>(); static void Main(string[] args) { for (int i = 0; i < 1000; i++) { //写入 _queue.Enqueue(i); } for (int i = 0; i < 1000; i++) { Task.Factory.StartNew(Go); } Console.ReadLine(); } public static void Go() { int o; if(_queue.TryDequeue(out o)) { list.Add(o); Console.WriteLine(list.Count()); } } }
时间: 2024-08-29 22:03:52