首页 / 软件开发 / .NET编程技术 / Windows 8 Store Apps学习（43） 多线程之任务

Windows 8 Store Apps学习（43） 多线程之任务2013-12-10 cnblogs webabcd多线程之任务: Task 基础, 多任务并行执行, 并行运算（Parallel）

介绍

重新想象 Windows 8 Store Apps 之 任务

Task - 基于线程池的任务（在 System.Threading.Tasks 命名空间下）

多 Task 的并行执行

Parallel - 并行计算（在 System.Threading.Tasks 命名空间下）

示例

1、演示 Task（基于线程池的任务）的基本应用

Thread/Tasks/TaskDemo.xaml

<Pagex:Class="XamlDemo.Thread.Tasks.TaskDemo"xmlns="http://schemas.microsoft.com/winfx/2006/xaml/presentation"xmlns:x="http://schemas.microsoft.com/winfx/2006/xaml"xmlns:local="using:XamlDemo.Thread.Tasks"xmlns:d="http://schemas.microsoft.com/expression/blend/2008"xmlns:mc="http://schemas.openxmlformats.org/markup-compatibility/2006"mc:Ignorable="d"><Grid Background="Transparent"><StackPanel Margin="120 0 0 0"><TextBlock Name="lblMsg" FontSize="14.667" /><Button Name="btnCreateTask" Content="执行一个没有返回值的任务" Click="btnCreateTask_Click_1" Margin="0 10 0 0" /><Button Name="btnCancelTask" Content="取消“执行一个没有返回值的任务”" Click="btnCancelTask_Click_1" Margin="0 10 0 0" /><Button Name="btnCreateTaskWithReturn" Content="执行一个带返回值的任务" Click="btnCreateTaskWithReturn_Click_1" Margin="0 30 0 0" /><Button Name="btnCancelTaskWithReturn" Content="取消“执行一个带返回值的任务”" Click="btnCancelTaskWithReturn_Click_1" Margin="0 10 0 0" /></StackPanel></Grid></Page>

Thread/Tasks/TaskDemo.xaml.cs

/* * Task - 基于线程池的任务（在 System.Threading.Tasks 命名空间下） */using System;using Windows.UI.Xaml;using Windows.UI.Xaml.Controls;using System.Threading.Tasks;using System.Threading;using Windows.UI.Core;namespace XamlDemo.Thread.Tasks{public sealed partial class TaskDemo : Page{/* * CancellationTokenSource - 用于取消 CancellationToken* Token - 一个 CancellationToken 类型的对象，用于关联 Task * IsCancellationRequested - 是否收到了取消操作的请求 * Cancel（） - 发出取消操作的请求 ** CancellationToken - 用于关联 Task，以便取消 Task * IsCancellationRequested - 是否收到了取消操作的请求 * WaitHandle - 信号，可以通过 WaitHandle.WaitOne（） 在当前线程等待 * ThrowIfCancellationRequested（） - 如果收到了取消操作的请求，则抛出一个OperationCanceledException 异常 */private CancellationTokenSource _cts;public TaskDemo（）{this.InitializeComponent（）;}private void btnCreateTask_Click_1（object sender, RoutedEventArgs e）{_cts = new CancellationTokenSource（）;// 实例化一个 Task，可随时通过 task.Status 获取任务状态Task task = new Task（（ctx） => // 任务所调用的方法，没有返回值{// 在当前线程上阻塞 3000 毫秒（当收到取消请求时会发出信号，停止阻塞）_cts.Token.WaitHandle.WaitOne（3000）;// 收到取消操作的请求后抛出一个 OperationCanceledException 异常，其会导致task.IsCanceled 的值变为 true// 此处的代码等同于 _cts.Token.ThrowIfCancellationRequested（）;if （_cts.IsCancellationRequested）throw new OperationCanceledException（_cts.Token）;},null, // 上下文对象，task.AsyncState 可获取到此对象，上面的 ctx 也可获取到此对象_cts.Token // 关联的 CancellationToken 对象，用于取消操作）;// 开始执行任务task.Start（）;// task.Wait（）; 在当前线程上等待任务执行完lblMsg.Text = "执行了一个没有返回值的任务，3 秒后执行完毕";// 任务执行完毕后的处理（注：ContinueWith 方法支持任意次回调，即可以写多个task.ContinueWith（） 都会被回调）task.ContinueWith（（ctx） => // 任务执行完毕后所调用的方法{if （ctx.IsCanceled） // 任务被取消{var ignored = Dispatcher.RunAsync（CoreDispatcherPriority.High,（） =>{lblMsg.Text += Environment.NewLine;lblMsg.Text += "取消了“执行一个没有返回值的任务”";}）;}if （ctx.IsFaulted） // 任务发生了一个未处理异常{var ignored = Dispatcher.RunAsync（CoreDispatcherPriority.High,（） =>{lblMsg.Text += Environment.NewLine;lblMsg.Text += "“执行一个没有返回值的任务”发生了一个未处理异常";}）;}if （ctx.IsCompleted） // 任务已完成（任务成功地执行完毕或被取消或发生了未处理异常都会 ctx.IsCompleted == true）{var ignored = Dispatcher.RunAsync（CoreDispatcherPriority.High,（） =>{lblMsg.Text += Environment.NewLine;lblMsg.Text += "“执行一个没有返回值的任务”执行完成，taskId: " + ctx.Id.ToString（）;}）;}}）;}private void btnCancelTask_Click_1（object sender, RoutedEventArgs e）{// 发出取消操作的请求_cts.Cancel（）;// _cts.CancelAfter（1000）; // 1000 毫秒后发出取消操作的请求}private void btnCreateTaskWithReturn_Click_1（object sender, RoutedEventArgs e）{_cts = new CancellationTokenSource（）;Func<object, string> handler = delegate（object state） // state 是传递过来的上下文对象{// 在当前线程上阻塞 3000 毫秒（当收到取消请求时会发出信号，停止阻塞）_cts.Token.WaitHandle.WaitOne（3000）;// 收到取消操作的请求后抛出一个 OperationCanceledException 异常，其会导致task.IsCanceled 的值变为 true// 此处的代码等同于 _cts.Token.ThrowIfCancellationRequested（）;if （_cts.IsCancellationRequested）throw new OperationCanceledException（_cts.Token）;return "我是“执行一个带返回值的任务”的返回值";};// Task.Factory.StartNew（） - 创建任务并马上执行，可随时通过 task.Status 获取任务状态// Task.Run（） 同样是创建任务并马上执行Task<string> task = Task.Factory.StartNew<string>（handler, // 任务所调用的方法，带返回值null, // 上下文对象，task.AsyncState 可获取到此对象_cts.Token // 关联的 CancellationToken 对象，用于取消操作）;lblMsg.Text = "执行了一个带返回值的任务，3 秒后执行完毕";// 任务执行完毕后的处理（注：ContinueWith 方法支持任意次回调，即可以写多个task.ContinueWith（） 都会被回调）task.ContinueWith（（ctx） =>{if （ctx.IsCanceled） // 任务被取消{var ignored = Dispatcher.RunAsync（CoreDispatcherPriority.High,（） =>{lblMsg.Text += Environment.NewLine;lblMsg.Text += "取消了“执行一个带返回值的任务”";}）;}if （ctx.IsFaulted） // 任务发生了一个未处理异常{var ignored = Dispatcher.RunAsync（CoreDispatcherPriority.High,（） =>{lblMsg.Text += Environment.NewLine;lblMsg.Text += "“执行一个带返回值的任务”发生了一个未处理异常";}）;}if （ctx.IsCompleted） // 任务已完成（任务成功地执行完毕或被取消或发生了未处理异常都会 ctx.IsCompleted == true）{var ignored = Dispatcher.RunAsync（CoreDispatcherPriority.High,（） =>{lblMsg.Text += Environment.NewLine;lblMsg.Text += "“执行一个带返回值的任务”执行完成，taskId: " + ctx.Id.ToString（）;}）;// 当任务成功地执行完毕时，输出任务的返回值if （！ctx.IsCanceled && ！ctx.IsFaulted）{ignored = Dispatcher.RunAsync（CoreDispatcherPriority.High,（） =>{lblMsg.Text += Environment.NewLine;// 任务的返回值lblMsg.Text += ctx.Result;}）;}}}）;}private void btnCancelTaskWithReturn_Click_1（object sender, RoutedEventArgs e）{// 发出取消操作的请求_cts.Cancel（）;// _cts.CancelAfter（1000）; // 1000 毫秒后发出取消操作的请求}}}