异步编程代码记录

                        #region 每个思考时间完成以后发送指定的数据量，不管服务器是否处理完

                        for (int i = 0; i < _threadNumber; i++)
                        {
                            Task.Factory.StartNew(new Action<object>(t =>
                            {
                                PrintLog($@"ThreadId:{Thread.CurrentThread.ManagedThreadId},Starting Process {i}");
                                Do((int)t);
                            }), i);
                        }

                        #endregion
                        
                        #region 发送N次请求以后等待所有线程完成，等服务器处理完所有的请求后，再执行下一次发送
                        //var tasks = new List<Task<Tuple<int, bool>>>();
                        //for (int i = 0; i < _threadNumber; i++)
                        //{
                        //    PrintLog($@"ThreadId:{Thread.CurrentThread.ManagedThreadId},Starting Process {i}");
                        //    tasks.Add(DoAsync(i));
                        //}

                        //foreach (var task in Task.WhenAll(tasks).GetAwaiter().GetResult())
                        //{
                        //    if (task.Item2)
                        //    {
                        //        PrintLog($@"ThreadId:{Thread.CurrentThread.ManagedThreadId},Ending Process {task.Item1}:{task.Item2}");
                        //    }
                        //}
                        #endregion

        public void Do(int i)
        {
            PrintLog($@"ThreadId:{Thread.CurrentThread.ManagedThreadId},working..{i}");
            Thread.Sleep(1000);
            PrintLog($@"ThreadId:{Thread.CurrentThread.ManagedThreadId},worked..{i}");
        }


        public async Task<Tuple<int, bool>> DoAsync(int i)
        {
            PrintLog($@"ThreadId:{Thread.CurrentThread.ManagedThreadId},working..{i}");
            await Task.Delay(3000);
            PrintLog($@"ThreadId:{Thread.CurrentThread.ManagedThreadId},worked..{i}");
            return Tuple.Create(i, true);
        }