Task 实现多线程的模板

 

 

1.Task多线程简单模板

 

1. using System;
2. using System.Collections.Generic;
3. using System.Threading.Tasks;
5. namespace Exercises
6. {
7.     public
   class GroupInfo
8.     {
9.         public
   string GroupId { get; set; }
10.         public
    string Data { get; set; }
11.     }
13.     public
    class MutilTaskTemplate
14.     {
15.         //执行此方法，可以看到效果
16.         public
    void Test()
17.         {
18.             Run();
19.         }
21.         public IEnumerable<GroupInfo> GetGroupInfos()
22.         {
23.             return
    new List<GroupInfo>() {
24.                 new GroupInfo(){ GroupId = Guid.NewGuid().ToString(), Data = "what!"},
25.                 new GroupInfo(){ GroupId = Guid.NewGuid().ToString(), Data = "hello!"},
26.                 new GroupInfo(){ GroupId = Guid.NewGuid().ToString(), Data = "world!"},
27.                 new GroupInfo(){ GroupId = Guid.NewGuid().ToString(), Data = "hehe!"}
28.             };
29.         }
31.         public
    void Run()
32.         {
33.             Console.WriteLine("start!");
35.             var groupInfos = GetGroupInfos();
37.             List<Task> groupInfoTasks = new List<Task>();
38.             foreach (var groupInfo in groupInfos)
39.             {
40.                 var task = new Task((inGroupInfo) =>
41.                 {
42.                     ForEveryGroup(inGroupInfo as GroupInfo);
43.                 }, groupInfo);
45.                 groupInfoTasks.Add(task);
46.             }
48.             Parallel.ForEach(groupInfoTasks, (t) => { t.Start(); });
49.             Task.WaitAll(groupInfoTasks.ToArray());
51.             Console.WriteLine("over!");
52.         }
54.         private
    void ForEveryGroup(GroupInfo groupInfo)
55.         {
56.             Console.WriteLine();
57.             Console.WriteLine(groupInfo.GroupId);
58.             //use the groupInfo.Data;
59.             Console.WriteLine(groupInfo.Data);
60.         }
61.     }
62. }

 

 

执行结果：

 

 

2.Task多线程带子线程模板

1. using System;
2. using System.Collections.Generic;
3. using System.Threading.Tasks;
4. using System.Linq;
6. namespace Exercises
7. {
8.     public
   class GroupInfo2
9.     {
10.         public
    string GroupId { get; set; }
12.         public List<RealData> Datas { get; set; }
13.     }
15.     public
    class RealData
16.     {
17.         public RealData(string name, int age)
18.         {
19.             this.Name = name;
20.             this.Age = age;
21.         }
22.         public
    string Name { get; set; }
23.         public
    int Age { get; set; }
24.     }
26.     public
    class MutilTaskWithSubTaskTemplate
27.     {
28.         //执行此方法，可以看到效果
29.         public
    void Test()
30.         {
31.             Run();
32.         }
34.         public IEnumerable<GroupInfo2> GetGroupInfos()
35.         {
36.             return
    new List<GroupInfo2>() {
37.                 new GroupInfo2(){ GroupId = Guid.NewGuid().ToString(), Datas = new List<RealData>(){
38.                     new RealData("daniu",26),new RealData("daniu2",27),new RealData("daniu3",28)} },
40.                 new GroupInfo2(){ GroupId = Guid.NewGuid().ToString(), Datas = new List<RealData>(){
41.                     new RealData("pzdn",26),new RealData("pzdn2",27)} },
43.                 new GroupInfo2(){ GroupId = Guid.NewGuid().ToString(), Datas = new List<RealData>(){
44.                     new RealData("pozi",26),new RealData("pozi2",27),new RealData("pozi3",28)} },
46.                 new GroupInfo2(){ GroupId = Guid.NewGuid().ToString(), Datas = new List<RealData>(){
47.                     new RealData("douzi",26),new RealData("douzi2",27),new RealData("douzi3",28)} }
48.             };
49.         }
51.         public
    void Run()
52.         {
53.             Console.WriteLine("start!");
55.             var groupInfos = GetGroupInfos();
57.             int splitNumber = 2; //2条数据一个Task，改变此数值，则可以控制每条子线程的执行数据量
59.             List<Task> groupInfoTasks = new List<Task>();
60.             foreach (var groupInfo in groupInfos)
61.             {
62.                 var task = new Task((inGroupInfo) =>
63.                 {
64.                     int remainData = groupInfo.Datas.Count % splitNumber;
65.                     int splits = groupInfo.Datas.Count / splitNumber + (remainData != 0 ? 1 : 0);
67.                     var tmpGroupInfo = inGroupInfo as GroupInfo2;
69.                     for (int i = 0; i < splits; i++)
70.                     {
71.                         bool flag = (i == splits - 1) && remainData != 0;
73.                         //当前分组的子线程
74.                         var subTask = new Task((inList) =>
75.                         {
76.                             ForEveryGroup(groupInfo.GroupId, inList as IEnumerable<RealData>);
77.                         }, tmpGroupInfo.Datas.Skip(splitNumber * i).Take(flag ? remainData : splitNumber), TaskCreationOptions.AttachedToParent);
79.                         subTask.Start();
80.                     }
82.                 }, groupInfo);
84.                 groupInfoTasks.Add(task);
85.             }
87.             Parallel.ForEach(groupInfoTasks, (t) => { t.Start(); });
88.             try
89.             {
90.                 Task.WaitAll(groupInfoTasks.ToArray());
91.             }
92.             catch (AggregateException e)　　//AggregateException可以捕获运行中出现的错误
93.             {
94.                 Console.WriteLine("Caught Exception:" + e.InnerException.Message);　//这里显示
95.             }
97.             Console.WriteLine("over!");
98.         }
100.         private
     void ForEveryGroup(string groupId, IEnumerable<RealData> realDatas)
101.         {
102.             Console.WriteLine(groupId);
103.             //use the groupInfo.Data;
104.             Console.WriteLine(realDatas == null);
105.             foreach (var item in realDatas)
106.             {
107.                 Console.WriteLine(item.Name + "-" + item.Age);
108.             }
109.         }
110.     }
111. }

 

 

执行结果：

 

3.加入超时

可以增加一个等待超时的字段，在Task.WaitAll(groupInfoTasks.ToArray(),timeOut);