一、概念
TPL的核心就是任务,一个任务代表一个异步操作,该操作可以通过多种方式运行,一个任务也可以由多个任务组成。
二、应用
1、创建任务有三种方法:
var t1 = new Task(() => TaskMethod("Task 1")); //通过Task构造函数创建 var t2 = new Task(() => TaskMethod("Task 2")); t2.Start(); //需要手动启动 t1.Start(); Task.Run(() => TaskMethod("Task 3")); //Task.Run()可以自启动 Task.Factory.StartNew(() => TaskMethod("Task 4")); //Task.Factory.StartNew()相对于前者要可以添加附加选项,如下添加了标记任务为长时间运行 Task.Factory.StartNew(() => TaskMethod("Task 5"),TaskCreationOptions.LongRunning); Sleep(TimeSpan.FromSeconds(1)); Console.ReadKey();
创建的任务都会被放入线程池,而且没有指定顺序。Task 5 经过标记后,不会使用线程池。
2、基本操作
Task<int> task = new Task<int>(()=>TaskMethod(name)); task.RunSynchronously();
//通过该方法运行的任务会运行在主线程上,可以避免使用线程池来执行非常短暂的操作
firstTask.ContinueWith(t => WriteLine(); // 该代码表示当firstTask这个任务的一个后续操作,在当前任务完成后运行 Task continuation = secondTask.ContinueWith(t => WriteLine(..., TaskContinuationOptions.OnlyOnRanToCompletion| TaskContinuationOptions.ExecuteSynchronously);
//TaskContinuationOptions.OnlyOnRanToCompletion| TaskContinuationOptions.ExecuteSynchronously //用来尝试同步后续操作
创建子任务:
firstTask = new Task<int>(() => { var innerTask = Task.Factory.StartNew(() => TaskMethod( "Second Task", 5), TaskCreationOptions.AttachedToParent); innerTask.ContinueWith(t => TaskMethod("Third Task", 2), TaskContinuationOptions.AttachedToParent); return TaskMethod("First Task", 2); }); //上述TaskCreationOptions.AttachedToParent运行了一个子任务 //通过TaskContinuationOptions.AttachedToParent给子任务一个后续操作,该操作会影响到父任务 //因为父任务必须等到所有的子任务结束它才会运行完
取消操作:
var cts = new CancellationTokenSource(); var longTask = new Task<int>(() => TaskMethod("Task 1", 10, cts.Token), cts.Token); WriteLine(longTask.Status); cts.Cancel(); //此时状态为Canceled //longTask.Start(); WriteLine(longTask.Status); WriteLine("First task has been cancelled before execution"); cts = new CancellationTokenSource(); longTask = new Task<int>(() => TaskMethod("Task 2", 10, cts.Token), cts.Token); longTask.Start(); for (int i = 0; i < 5; i++) { Sleep(TimeSpan.FromSeconds(0.5)); WriteLine(longTask.Status); } cts.Cancel(); //此时任务的状态变为RanToCompletion //longTask.Start(); for (int i = 0; i < 5; i++) { Sleep(TimeSpan.FromSeconds(0.5)); WriteLine(longTask.Status); }