多线程之任务: Task 基础, 多任务并行执行, 并行运算（Parallel）
介绍
重新想象 Windows 8 Store Apps 之 任务
Task - 基于线程池的任务（在 System.Threading.Tasks 命名空间下）
多 Task 的并行执行
Parallel - 并行计算（在 System.Threading.Tasks 命名空间下）
示例
1、演示 Task（基于线程池的任务）的基本应用
Thread/Tasks/TaskDemo.xaml
<Page
x: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 毫秒后发出取消操作的请求
}
}
}
以上是小编为您精心准备的的内容，在的博客、问答、公众号、人物、课程等栏目也有的相关内容，欢迎继续使用右上角搜索按钮进行搜索cts
， text
， task
， 客户端取消异常
， 任务
， 一个
， 执行任务
执行完毕
，以便于您获取更多的相关知识。
时间： 2024-11-11 16:30:13