你的位置:首页 > ASP.net教程

[ASP.net教程]Task三个列子的分享


这次要分享的是C#Task任务的几个列子,感觉最实用的是封装的分页任务执行方法,这个方法步奏也是目前在我工作中执行多任务常用的,不知道各位也有这用的情况,那么开始吧。

1.顺序任务执行

 1 //顺序任务执行 2       Task.Factory.StartNew<int>(() => { Console.WriteLine(1); return 1; }). 3         //等待5s以后才会依次输出2,3 4         ContinueWith((task) => 5          { 6  7           Stopwatch wt = new Stopwatch(); 8            wt.Start(); 9           Thread.Sleep(1000 * 5);10            wt.Stop();11           Console.WriteLine("等待了:{0}ms,输出结果{1}", wt.ElapsedMilliseconds, 2);12          }).13         ContinueWith((task) => { Console.WriteLine(3); }).14         Wait();

View Code

  上面的代码中也备注了一些文字说明,其中有关键词语及意思如下:

  .Task.Factory.StartNew:创建一个Task实例,创建后自动开启,无需在调用Start;

  .ContinueWith:看单词的意思就明了,是继续的意思,在这里的效果也是等待上一个Task执行完毕了在继续执行本次任务,这里方法里面每个任务是一层一层传递的

  效果图:

  

  这里有个地方注意,sleep这是了5s但是这里使用Stopwatch统计出来只有4999ms,这个地方存在差异性,本章不解释,有兴趣朋友可以分享下或研究下。

 

  2.并行任务效果

 1 //并行任务 2       var watch = new Stopwatch(); 3       //func方法(认知特点:任意长度参数,最后一个的类型是方法返回的返回值类型) 4       Func<object, int> fun = (num) => 5       { 6         Thread.Sleep(1000 * 2); 7         Console.WriteLine("第{0}个", num); 8         return Convert.ToInt32(num); 9       };10       var len = 5;11       var tasks = new Task<int>[len];12       //开始计算处理时间13       watch.Start();14       for (int _i = 0; _i < len; _i++)15       {16         //Task.Factory.StartNew直接开启Task任务无需在使用start17         tasks[_i] = Task.Factory.StartNew<int>(fun, _i);18       }19       //10s等待20       Task.WaitAll(tasks, 1000 * 10);21       watch.Stop();22       Console.WriteLine("tasks共使用时间:{0}s={1}ms", watch.ElapsedMilliseconds / 1000, watch.ElapsedMilliseconds);

View Code

  关键词语及意思如下:

  .Func<object, int>这个是C#新增的特性,这个和Action最大的区别就是Func有返回值,其他的和Action相同任意长度参数个数和类型

  .Task.WaitAll这个方法有几个重载,这里用的是一个超时时间的方法,设置时间后在规定的时间就不继续等待Task【】了,如果task【】在超时时间范围内就执行完了,那么直接通过,不用再等待超时时间

  效果:

  

这里依然有统计时间查问题,忽略

 

3.分页任务执行方法

 1 /// <summary> 2     /// 批次任务执行方法 3     /// </summary> 4     /// <typeparam name="T">参数类型</typeparam> 5     /// <param name="func">func方法</param> 6     /// <param name="list">待执行数据</param> 7     /// <param name="taskLen">任务量</param> 8     /// <param name="timeOut">任务超时时间 默认30s</param> 9     /// <returns></returns>10     public static int _ExcuteTask<T>(Func<List<T>, int> func, List<T> list, int taskLen = 10, int timeOut = 30) where T : class11     {12       var result = 0;13       //任务量14       var tasks = new Task<int>[taskLen];15       var page = list.Count / taskLen + (list.Count % taskLen > 0 ? 1 : 0); //每个分得得需要执行的总条数 最有一个执行剩余所有16       for (var ji = 1; ji <= taskLen; ji++)17       {18         //使用分页方法获取待执行数据19         var list01 = list.Skip((ji - 1) * page).Take(page).ToList();20         if (list01.Count <= 0) { break; }21         var task = Task.Run(() =>22         {23 24           return func(list01);25         });26         tasks[ji - 1] = task;27       }28       //等待执行29       Task.WaitAll(tasks, 1000 * 1 * timeOut);30       //获取执行成功条数31       result = tasks.Where(b => b.IsCompleted).Sum(b => b.Result);32 33       return result;34     }

View Code

  测试代码:

 1 /// <summary> 2     /// 测试执行底层数据方法 3     /// </summary> 4     /// <param name="list"></param> 5     /// <returns></returns> 6     static int _FuncTest(List<string> list) 7     { 8  9       foreach (var item in list)10       {11         Thread.Sleep(1000 * 2);12         Console.WriteLine("TaskId:{1}输出第{0}个值", item, Task.CurrentId);13       }14       return list.Count;15     }

View Code
 1 //分页任务执行方法 2       var listT = new List<string>(); 3       for (int _i = 0; _i < 9; _i++) 4       { 5         listT.Add(_i.ToString()); 6       } 7       watch.Restart(); 8       //调用任务公共方法 9       var result = _ExcuteTask(_FuncTest, listT, 3);10       watch.Stop();11       Console.WriteLine("待处理数据:{0}条,共处理成功数据:{1}条,使用时间:{2}ms", listT.Count, result, watch.ElapsedMilliseconds);

View Code

  这里使用的是分页的原理,把参数集合分发到创建的Task中,使用Task【】来处理这些数据,这里和第二个例子有点相识就多了分页写法而已,最后统计执行成功的条数,以此来返回给调用者,方便记录日志,此方法目前是我经常使用的,不知道是否还有更好的,各位多多分享,谢谢。

  效果图:

  

  以上就是这次的总结,希望多同学们有些帮助,有疑问或者问题请及时相互交流。