Question

求一个C#使用Queue的一个生产者多个消费者（多线程）的示例，谢谢！

一个生产者线程，每次读取文件一行加入到Queue里，文件读取完毕后，线程完毕。
多个消费者线程，从Queue里取数据进行处理。
如有Q聊最好，谢谢。

Answer 1

class queueThread
    {

        private object locker = new object();
        private Queue queue = new Queue();

        private bool isStart = false;
        public void Start()
        {
            if (isStart) return;
            isStart = true;
            //生产者
            var thread1 = new Thread(() => AddQueueWorker());
            thread1.Start();

            //消费者
            var thread2 = new Thread(() => GetQueueWorker());
            thread2.Start();
        }


        private void AddQueueWorker()
        {
            lock (locker)
            {
                var fileLine = File.OpenText(@"d:\\file.txt");
                var strLine = string.Empty;
                while ((strLine = fileLine.ReadLine()) != null)
                {
                    queue.Enqueue(strLine);
                }
            }
        }

        private void GetQueueWorker()
        {
            while (true)
            {
                lock (locker)
                {
                    if (queue.Count == 0)
                        break;

                    var obj = queue.Dequeue();
                    if (obj == null)
                        continue;

                    //obj 是获取的值，要做点什么？

                }
            }

            isStart = false;
        }
    }

Answer 2

你看看，闲着瞎写的~~

兄弟都下了我的源码，不给点意见或者加分谁不过去吧