C#队列Queue，利用队列处理订单

一、什么是队列

队列（Queue）代表了一个先进先出的对象集合。当您需要对各项进行先进先出的访问时，则使用队列。当您在列表中添加一项，称为入队，当您从列表中移除一项时，称为出队。

这是摘抄网上的。做了个demo，但笔者技术有限，如有改进的地方，欢迎大神多多指导。

二、利用队列来处理订单问题

思路：开启一个线程去创建订单，同时处理订单线程开启，如队列里有订单，那么就处理，直到没有就一直处于等待状态（这里我等待20次就退出），等待订单加入队列再继续处理订单。

1、新建一个订单OrderInfo（用的是结构）

    public struct OrderInfo

    {

        public int OrderId { get; set; }

        public int ProductId { get; set; }

        public Decimal Price { get; set; }

        public string Remarks { get; set; }

    }

2、到控制执行

    class Program

    {

        public static readonly Queue<OrderInfo> queue = new Queue<OrderInfo>();

        public static object obj = new object();

        static void Main(string[] args)

        {

            #region 模仿淘宝处理订单问题

            //订单进入队列等待

            Task OrderTask = new Task(CreateOrder);

            OrderTask.Start();

            //开启线程处理订单

            Task taskDeal = new Task(DealOrder);

            taskDeal.Start();

            Console.WriteLine("hello");

            #endregion

            Console.ReadKey();

        }

        public static void CreateOrder()

        {

            for (int i = ; i < ; i++)

            {

                Thread.Sleep();

                lock (obj)

                {

                    OrderInfo order = new OrderInfo();

                    order.OrderId = i;

                    order.ProductId =  + i;

                    order.Price = ;

                    order.Remarks = "quick send goods";

                    queue.Enqueue(order);

                    Console.WriteLine("添加了一条订单" + i);

                }

            }

        }

        public static int flag = ;

        public static void DealOrder()

        {

            while (true)

            {

                Thread.Sleep();

                if (queue.Count > )

                {

                    lock (obj)

                    {

                        if (queue.Count > )

                        {

                            OrderInfo order = queue.Dequeue();

                            Console.WriteLine("处理==>订单号{0}；商品：{1}价格：{2}", order.OrderId, order.ProductId, order.Price);

                        }

                    }

                }

                else

                {

                    Thread.Sleep();

                    flag++;

                    if (flag > ) { Console.WriteLine("All Over"); break; }

                    lock (obj)

                    {

                        if (queue.Count <= )

                        {

                            Console.WriteLine("订单处理完成，等待中。。。");

                        }

                    }

                }

            }

        }

    }

测试截图如下：

C#队列Queue，利用队列处理订单的相关教程结束。