8天玩转并行开发——第①天 Task的采取

     

      Windows Embedded Compact
7试用版已经昭示一段时间了,微软官网提供的是在线安装包,不太方便下载和装置。微软嵌入式普通话社区提供了离线安装包的下载,地址如下:

   
 在大家领会Task从前,如果大家要选拔多核的效能大概就会本人来开线程,然则那种线程模型在.net
4.0后头被一种叫做基于

http://download.winitpro.com.cn/MS/MSEmbed/WinCompact7evaluation_1.rar
http://download.winitpro.com.cn/MS/MSEmbed/WinCompact7evaluation_2.rar

“任务的编制程序模型”所冲击,因为task会比thread具有更小的性格费用,然则大家自然会有思疑,职务和线程到底有哪些分别?

     
多谢大卫.Zang提供了造福,让广大WinCE的开发人士能在第目前直接触到WinCE7.0。

 

1:义务是架设在线程之上的,也正是说职责最后依旧要抛给线程去实践。

2:任务跟线程不是一定的涉嫌,比如开13个任务并不是说会开十三个线程,那点职务有点类似线程池,不过职责相比较线程池有非常小

      的花费和标准的决定。

 

一:Task

  1. 最简便的行使

  开启task有三种方法:

<1> 实例化Task

1    //第一种方式开启
2         var task1 = new Task(() =>
3         {
4             Run1();
5         });

 

<2>从工厂中开创

1   var task2 = Task.Factory.StartNew(() =>
2             {
3                 Run2();
4             });

不错,同样二种办法都得以创建,大家一定会想相互是或不是多多少少有点分别吗?好的,下边我们举个例子看领会。

 1 using System;
 2 using System.Threading;
 3 using System.Threading.Tasks;
 4 using System.Diagnostics;
 5 using System.Collections.Generic;
 6 
 7 class Program
 8 {
 9     static void Main(string[] args)
10     {
11         //第一种方式开启
12         var task1 = new Task(() =>
13         {
14             Run1();
15         });
16 
17         //第二种方式开启
18         var task2 = Task.Factory.StartNew(() =>
19             {
20                 Run2();
21             });
22 
23         Console.WriteLine("调用start之前****************************\n");
24 
25         //调用start之前的“任务状态”
26         Console.WriteLine("task1的状态:{0}", task1.Status);
27 
28         Console.WriteLine("task2的状态:{0}", task2.Status);
29 
30         task1.Start();
31 
32         Console.WriteLine("\n调用start之后****************************");
33 
34         //调用start之前的“任务状态”
35         Console.WriteLine("\ntask1的状态:{0}", task1.Status);
36 
37         Console.WriteLine("task2的状态:{0}", task2.Status);
38 
39         //主线程等待任务执行完
40         Task.WaitAll(task1, task2);
41 
42         Console.WriteLine("\n任务执行完后的状态****************************");
43 
44         //调用start之前的“任务状态”
45         Console.WriteLine("\ntask1的状态:{0}", task1.Status);
46 
47         Console.WriteLine("task2的状态:{0}", task2.Status);
48 
49         Console.Read();
50     }
51 
52     static void Run1()
53     {
54         Thread.Sleep(1000);
55         Console.WriteLine("\n我是任务1");
56     }
57 
58     static void Run2()
59     {
60         Thread.Sleep(2000);
61         Console.WriteLine("我是任务2");
62     }
63 }

葡京在线开户 1

①:从图中能够看到二种task实例的简约生命周期。

Created:表示暗许开首化职分,不过大家发现“工厂创设的”实例直接跳过。

WaitingToRun: 这种情状表示等待职务调度器分配线程给职务履行。

RanToCompletion:职责履行完结。

②:大家发现task的使用跟Thread很一般,就连waitAll的主意运用也一致,刚才也说了,职分是架设在线程之上,那么大家用VS里面包车型客车

     
“并行任务”看一看,神速键Ctrl+D,K,或许找到“调节和测试”->”窗口“->”并行职务“,大家在WaitAll方法处插入3个断点,最终我们发现

      职务真正托管给了线程。

葡京在线开户 2

 

  1. 葡京在线开户,注销职分

 
 大家清楚task是并行计算的,比如说主线程在有些时刻由于某种原因要注销有个别task的实践,我们能实现呢?
当然大家得以做到。

在4.0中给大家提供3个“撤废标记”叫做CancellationTokenSource.Token,在成立task的时候传出此参数,就能够将主线程和职责相

涉嫌,然后在职务中安装“废除信号“叫做ThrowIfCancellationRequested来等待主线程使用Cancel来通告,一旦cancel被调用。task将会

抛出OperationCanceledException来刹车此职责的推行,最终将眼下task的Status的IsCanceled属性设为true。看起来是或不是很空洞,

没什么,上代码说话。

 1 using System;
 2 using System.Threading;
 3 using System.Threading.Tasks;
 4 using System.Diagnostics;
 5 class Program
 6 {
 7     static void Main(string[] args)
 8     {
 9         var cts = new CancellationTokenSource();
10         var ct = cts.Token;
11 
12         Task task1 = new Task(() => { Run1(ct); }, ct);
13 
14         Task task2 = new Task(Run2);
15 
16         try
17         {
18             task1.Start();
19             task2.Start();
20 
21             Thread.Sleep(1000);
22 
23             cts.Cancel();
24 
25             Task.WaitAll(task1, task2);
26         }
27         catch (AggregateException ex)
28         {
29             foreach (var e in ex.InnerExceptions)
30             {
31                 Console.WriteLine("\nhi,我是OperationCanceledException:{0}\n", e.Message);
32             }
33 
34             //task1是否取消
35             Console.WriteLine("task1是不是被取消了? {0}", task1.IsCanceled);
36             Console.WriteLine("task2是不是被取消了? {0}", task2.IsCanceled);
37         }
38 
39         Console.Read();
40     }
41 
42     static void Run1(CancellationToken ct)
43     {
44         ct.ThrowIfCancellationRequested();
45 
46         Console.WriteLine("我是任务1");
47 
48         Thread.Sleep(2000);
49 
50         ct.ThrowIfCancellationRequested();
51 
52         Console.WriteLine("我是任务1的第二部分信息");
53     }
54 
55     static void Run2()
56     {
57         Console.WriteLine("我是任务2");
58     }
59 }

从图中能够阅览

①:Run第11中学的Console.WriteLine(“作者是职责1的第1有的音信”); 没有被实施。

②:Console.WriteLine(“task1是或不是被废除了? {0}”, task1.IsCanceled);
状态为True。

也就报告大家Run第11中学途被主线程中断执行,我们coding的代码起到功效了。

葡京在线开户 3

 

  1. 获得职分的重返值

 
大家原先写线程的时候注册的章程一般都以void类型,借使主线程要从办事线程中获取数据一般选择的手腕是“委托+事件”的情势,然则

在Task中有三种格局得以缓解。

<1>
 现在我们的实例化是选择Task<TResult>的格局,在那之中TResult正是近期task执行后赶回的结果,上面举得例子是t2职分获得

         t1的施行结果。

 1 using System;
 2 using System.Threading;
 3 using System.Threading.Tasks;
 4 using System.Diagnostics;
 5 using System.Collections.Generic;
 6 
 7 class Program
 8 {
 9     static void Main(string[] args)
10     {
11         //执行task1
12         var t1 = Task.Factory.StartNew<List<string>>(() => { return Run1(); });
13 
14         t1.Wait();
15 
16         var t2 = Task.Factory.StartNew(() =>
17         {
18             Console.WriteLine("t1集合中返回的个数:" + string.Join(",", t1.Result));
19         });
20 
21         Console.Read();
22     }
23 
24     static List<string> Run1()
25     {
26         return new List<string> { "1", "4", "8" };
27     }
28 }

葡京在线开户 4

<2>选用ContinueWith方法,很有意思,今后大家将地点的办法改造一下。

 1 using System;
 2 using System.Threading;
 3 using System.Threading.Tasks;
 4 using System.Diagnostics;
 5 using System.Collections.Generic;
 6 
 7 class Program
 8 {
 9     static void Main(string[] args)
10     {
11         //执行task1
12         var t1 = Task.Factory.StartNew<List<string>>(() => { return Run1(); });
13 
14         var t2 = t1.ContinueWith((i) =>
15         {
16             Console.WriteLine("t1集合中返回的个数:" + string.Join(",", i.Result));
17         });
18 
19         Console.Read();
20     }
21 
22     static List<string> Run1()
23     {
24         return new List<string> { "1", "4", "8" };
25     }
26 }

葡京在线开户 5

 

4:ContinueWith结合WaitAll来玩一把

   
当那二者结合起来,大家就足以玩一些错综复杂一点的东西,比如说未来有七个职责,在那之中t1需求串行,t2-t3得以相互,t4须求串行,t5-t6并行,

t7串行。

葡京在线开户 6

好了,大家上一下代码说话,上边代码没有实际意思,纯属演示。

 1 using System;
 2 using System.Threading;
 3 using System.Threading.Tasks;
 4 using System.Diagnostics;
 5 using System.Collections.Generic;
 6 using System.Collections.Concurrent;
 7 
 8 class Program
 9 {
10     static void Main(string[] args)
11     {
12         ConcurrentStack<int> stack = new ConcurrentStack<int>();
13 
14         //t1先串行
15         var t1 = Task.Factory.StartNew(() =>
16         {
17             stack.Push(1);
18             stack.Push(2);
19         });
20 
21         //t2,t3并行执行
22         var t2 = t1.ContinueWith(t =>
23         {
24             int result;
25 
26             stack.TryPop(out result);
27         });
28 
29         //t2,t3并行执行
30         var t3 = t1.ContinueWith(t =>
31         {
32             int result;
33 
34             stack.TryPop(out result);
35         });
36 
37         //等待t2和t3执行完
38         Task.WaitAll(t2, t3);
39 
40 
41         //t4串行执行
42         var t4 = Task.Factory.StartNew(() =>
43         {
44             stack.Push(1);
45             stack.Push(2);
46         });
47 
48         //t5,t6并行执行
49         var t5 = t4.ContinueWith(t =>
50         {
51             int result;
52 
53             stack.TryPop(out result);
54         });
55 
56         //t5,t6并行执行
57         var t6 = t4.ContinueWith(t =>
58         {
59             int result;
60 
61             //只弹出,不移除
62             stack.TryPeek(out result);
63         });
64 
65         //临界区:等待t5,t6执行完
66         Task.WaitAll(t5, t6);
67 
68         //t7串行执行
69         var t7 = Task.Factory.StartNew(() =>
70         {
71             Console.WriteLine("当前集合元素个数:" + stack.Count);
72         });
73 
74         Console.Read();
75     }
76 }

葡京在线开户 7