C# Task异步编程的实现示例
作者:普通网友
Task提供了一种更简洁的方式来处理异步编程,避免了传统多线程编程的复杂性,本文就来介绍一下C# Task异步编程的实现示例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
Task 的基本概念
在 C# 中,Task 是用于表示异步操作的类,属于 System.Threading.Tasks 命名空间。它提供了一种更简洁的方式来处理异步编程,避免了传统多线程编程的复杂性。Task 可以返回结果(通过 Task<TResult>)或仅表示操作完成(通过无返回值的 Task)。
创建 Task
通过 Task.Run 或 Task.Factory.StartNew 可以创建并启动一个任务。
// 无返回值的 Task
Task task = Task.Run(() => {
Console.WriteLine("任务执行中");
});
// 有返回值的 Task<int>
Task<int> taskWithResult = Task.Run(() => {
return 42;
});
等待 Task 完成
使用 await 或 Wait 方法可以等待任务完成。
// 使用 await(需在 async 方法中)
async Task ExecuteTaskAsync() {
await Task.Run(() => {
Console.WriteLine("任务完成");
});
}
// 使用 Wait(阻塞当前线程)
Task task = Task.Run(() => {
Console.WriteLine("任务完成");
});
task.Wait();
获取 Task 结果
对于有返回值的 Task<TResult>,可以通过 Result 属性获取结果。
Task<int> task = Task.Run(() => {
return 42;
});
int result = task.Result; // 阻塞直到任务完成
Console.WriteLine(result); // 输出 42
异常处理
Task 可以捕获异步操作中的异常,通过 AggregateException 处理。
Task task = Task.Run(() => {
throw new InvalidOperationException("任务出错");
});
try {
task.Wait();
} catch (AggregateException ex) {
foreach (var e in ex.InnerExceptions) {
Console.WriteLine(e.Message);
}
}
Task 的组合
Task.WhenAll 和 Task.WhenAny 可以组合多个任务。
Task task1 = Task.Run(() => { /* 任务1 */ });
Task task2 = Task.Run(() => { /* 任务2 */ });
// 等待所有任务完成
await Task.WhenAll(task1, task2);
// 等待任意一个任务完成
await Task.WhenAny(task1, task2);
取消 Task
通过 CancellationToken 可以取消任务。
CancellationTokenSource cts = new CancellationTokenSource();
Task task = Task.Run(() => {
while (true) {
if (cts.Token.IsCancellationRequested) {
break; // 取消任务
}
}
}, cts.Token);
// 取消任务
cts.Cancel();
异步方法中的 Task
在 async 方法中,Task 通常与 await 一起使用,实现非阻塞操作。
async Task<int> GetDataAsync() {
await Task.Delay(1000); // 模拟异步操作
return 42;
}
async Task Main() {
int result = await GetDataAsync();
Console.WriteLine(result);
}
到此这篇关于C# Task异步编程的实现示例的文章就介绍到这了,更多相关C# Task异步编程内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!
