?

?

1.Task多线程简单模板

?

1. using System;
2. using System.Collections.Generic;
3. using System.Threading.Tasks;
4. ?
5. namespace Exercises
6. {
7. ????public
   class GroupInfo
8. ????{
9. ????????public
   string GroupId { get; set; }
10. ????????public
    string Data { get; set; }
11. ????}
12. ?
13. ????public
    class MutilTaskTemplate
14. ????{
15. ????????//执行此方法，可以看到效果
16. ????????public
    void Test()
17. ????????{
18. ????????????Run();
19. ????????}
20. ?
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. ????????}
30. ?
31. ????????public
    void Run()
32. ????????{
33. ????????????Console.WriteLine("start!");
34. ?
35. ????????????var groupInfos = GetGroupInfos();
36. ?
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);
44. ?
45. ????????????????groupInfoTasks.Add(task);
46. ????????????}
47. ?
48. ????????????Parallel.ForEach(groupInfoTasks, (t) => { t.Start(); });
49. ????????????Task.WaitAll(groupInfoTasks.ToArray());
50. ?
51. ????????????Console.WriteLine("over!");
52. ????????}
53. ?
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;
5. ?
6. namespace Exercises
7. {
8. ????public
   class GroupInfo2
9. ????{
10. ????????public
    string GroupId { get; set; }
11. ?
12. ????????public List<RealData> Datas { get; set; }
13. ????}
14. ?
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. ????}
25. ?
26. ????public
    class MutilTaskWithSubTaskTemplate
27. ????{
28. ????????//执行此方法，可以看到效果
29. ????????public
    void Test()
30. ????????{
31. ????????????Run();
32. ????????}
33. ?
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)} },
39. ?
40. ????????????????new GroupInfo2(){ GroupId = Guid.NewGuid().ToString(), Datas = new List<RealData>(){
41. ????????????????????new RealData("pzdn",26),new RealData("pzdn2",27)} },
42. ?
43. ????????????????new GroupInfo2(){ GroupId = Guid.NewGuid().ToString(), Datas = new List<RealData>(){
44. ????????????????????new RealData("pozi",26),new RealData("pozi2",27),new RealData("pozi3",28)} },
45. ?
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. ????????}
50. ?
51. ????????public
    void Run()
52. ????????{
53. ????????????Console.WriteLine("start!");
54. ?
55. ????????????var groupInfos = GetGroupInfos();
56. ?
57. ????????????int splitNumber = 2; //2条数据一个Task，改变此数值，则可以控制每条子线程的执行数据量
58. ?
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);
66. ?
67. ????????????????????var tmpGroupInfo = inGroupInfo as GroupInfo2;
68. ?
69. ????????????????????for (int i = 0; i < splits; i++)
70. ????????????????????{
71. ????????????????????????bool flag = (i == splits - 1) && remainData != 0;
72. ?
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);
78. ?
79. ????????????????????????subTask.Start();
80. ????????????????????}
81. ?
82. ????????????????}, groupInfo);
83. ?
84. ????????????????groupInfoTasks.Add(task);
85. ????????????}
86. ?
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. ????????????}
96. ?
97. ????????????Console.WriteLine("over!");
98. ????????}
99. ?
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);