ConcurrentQueue表示线程安全的先进先出 (FIFO) 集合。

Posted 2020-10-06 积少成多

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

        }
    }