码迷,mamicode.com
首页 > 其他好文 > 详细

分享一段异步加队列的方法

时间:2015-09-15 18:30:24      阅读:137      评论:0      收藏:0      [点我收藏+]

标签:

        static void Main(string[] args)
        {
            List<Task> tlist = new List<Task>();
            var queue = ServiceContainer.GetQueue<Info>();
            for (int j = 0; j < 3; j++)
            { 
                for (int i = 0; i < 10; i++)
                {
                    tlist.Add( Task.Run(() =>
                    {
                        for (int z = 0;z < 10; z++)
                        {
                            queue.Enqueue(new Info() { Str = "DateTime:" + DateTime.Now.ToString() + "毫秒:" + DateTime.Now.Millisecond.ToString() + "  ;Num:" + z.ToString() });
                        }
                        ConsoleStr(queue, j);
                    }));
                }
                Task.WaitAll(tlist.ToArray());
            }

            System.Console.ReadKey();
        }

        private static void ConsoleStr(IQueue<Info> queue, int j)
        {
            while (queue != null && !queue.IsEmpty)
            {
                Info i = null;
                var q = queue.TryDequeue(out i);
                if (q &&  i!= null)
                {
                    System.Console.WriteLine(i.Str + "j:" + j.ToString());
                }
            }
        }

  

分享一段异步加队列的方法

标签:

原文地址:http://www.cnblogs.com/SharkLock-Chen/p/4810795.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!