• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

C#多线程与队列操作小练刀

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

之前写Web没有应用到多线程与队列的知识,写了个小程序,练了一把手,模拟商品抢购,代码如下:

 class Program
    {
        public static Random r = new Random();
        public static int GoodsStock = 30;
        public static Queue payq = new Queue();
        public static Queue waitq = new Queue();

        static void Main(string[] args)
        {
            //增加监视线程
            ThreadStart childref3 = new ThreadStart(LookAtActiveThread);
            Console.WriteLine("监视线程启动了!");
            Thread childThread3 = new Thread(childref3);
            childThread3.Start();
            //增加用户抢购线程
            ThreadStart childref1 = new ThreadStart(UserBuyInsertThread);
            Console.WriteLine("用户群1开始抢购了!");
            Thread childThread1 = new Thread(childref1);
            childThread1.Start();
            //增加用户抢购线程
            ThreadStart childref4 = new ThreadStart(UserBuyInsertThread);
            Console.WriteLine("用户群2开始抢购了!");
            Thread childThread4 = new Thread(childref4);
            childThread4.Start();
            //增加开始结账线程
            ThreadStart childref2 = new ThreadStart(UserPayEndThread);
            Console.WriteLine("结账线程启动了!");
            Thread childThread2 = new Thread(childref2);
            childThread2.Start();
            Console.ReadKey();
        }

        //监视线程,抢购结束后关闭所有线程
        public static void LookAtActiveThread()
        {
            DateTime TempDT = new DateTime();
            int totalCount = GoodsStock;
            while (true)
            {
                if (GoodsStock == 0 && payq.Count == 0 && waitq.Count == 0)
                {
                    TimeSpan ts = DateTime.Now.Subtract(TempDT);
                    Console.WriteLine("抢购活动已结束," + totalCount + "个商品已在" + ts.Seconds + "秒售罄 当前时间:" + DateTime.Now);
                    break;
                }
                else
                {
                    Thread.Sleep(100);
                }
            }
        }

        //购买用户随机排队插入队列 排队总人数不能超过10个
        public static void UserBuyInsertThread()
        {
            try
            {
                while (true)
                {
                    if (GoodsStock > 0)
                    {
                        //判断等待队列是否为空,付款队列是否已满,直接加入到付款队列中
                        if (waitq.Count==0 && payq.Count < GoodsStock)
                        {
                            int userid = r.Next(10000, 99999);
                            payq.Enqueue(userid);
                            Console.WriteLine("用户" + userid + "下单成功,请尽快付款 当前付款队列:" + payq.Count + " 当前时间:" + DateTime.Now);
                            Thread.Sleep(r.Next(100));
                        }
                        else
                        {
                            int userid = r.Next(10000, 99999);
                            waitq.Enqueue(userid);
                            Console.WriteLine("用户" + userid + "已加入到等待队列中 当前等待队列:" + waitq.Count + " 当前时间:" + DateTime.Now);
                            Thread.Sleep(r.Next(500, 2000));
                        }
                    }
                    else
                    {
                        Console.WriteLine("对不起,您来晚了,商品已售罄");
                        Thread.Sleep(300);
                    }
                    if (GoodsStock == 0 && payq.Count == 0 && waitq.Count == 0)
                    {
                        //停止线程
                        Console.WriteLine("排队线程结束 当前时间:" + DateTime.Now);
                        break;
                    }
                }
            }
            catch (ThreadAbortException e)
            {
                Console.WriteLine("用户排队线程出错了:" + e.ToString());
            }
        }

        //用户购买操作,付款时间比较随机
        public static void UserPayEndThread() 
        {
            try
            {
                while (true)
                {
                    if (payq.Count == 0 && waitq.Count == 0)
                    {
                        Thread.Sleep(300);
                    }
                    else
                    {
                        if (GoodsStock == 0)
                        {
                            if (waitq.Count > 0)
                            {
                                int userid = (int)waitq.Dequeue();
                                Console.WriteLine("对不起" + userid + ",商品已被抢购一空! 下次请努力! 当前时间:" + DateTime.Now);
                                Thread.Sleep(100);
                            }
                        }
                        else
                        {
                            if (payq.Count > 0)
                            {
                                int userid = (int)payq.Dequeue();
                                //用户一定概率的超时或者取消订单
                                if (r.Next(1, 10) < 3)
                                {
                                    Console.WriteLine("对不起,用户" + userid + "已超时或取消订单! 当前付款队列:" + payq.Count + " 当前时间:" + DateTime.Now + " 当前库存:" + GoodsStock);
                                }
                                else
                                {
                                    GoodsStock -= 1;
                                    Console.WriteLine("恭喜!用户" + userid + "已结账,购买成功! 当前付款队列:" + payq.Count + " 当前时间:" + DateTime.Now + " 当前库存:" + GoodsStock);
                                }
                                //把等待队列中的用户加入到付款队列中,判断付款队列中是否超过库存数量s
                                if (GoodsStock > 0 && GoodsStock > payq.Count && waitq.Count > 0)
                                {
                                    userid = (int)waitq.Dequeue();
                                    payq.Enqueue(userid);
                                    Console.WriteLine("用户" + userid + "已从排队队列加入到付款队列,请尽快付款!当前付款队列:" + payq.Count + " 当前时间:" + DateTime.Now + " 当前库存:" + GoodsStock);
                                }
                                Thread.Sleep(r.Next(100, 500));
                            }
                        }
                    }
                    if (GoodsStock == 0 && payq.Count == 0 && waitq.Count == 0)
                    {
                        //停止线程
                        Console.WriteLine("付款线程结束 当前时间:" + DateTime.Now);
                        break;
                    }
                }
            }
            catch (ThreadAbortException e)
            {
                Console.WriteLine("用户结账线程出错了:" + e.ToString());
            }
        }
    }
View Code

 


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
c#基础知识总结(一)--菜鸟篇发布时间:2022-07-14
下一篇:
C#下载doc文件直接返回文件流发布时间:2022-07-14
热门推荐
热门话题
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap