在C#的开发体系中，Task是.NET Framework 4.0引入的任务并行库核心类型，它基于线程池实现，相比传统的Thread类型，使用起来更加轻量，也更适合处理异步和并行场景。通过Task可以很方便地启动多个并行任务，让多个操作同时执行，减少整体耗时。
Task的基础创建方式
创建Task主要有两种方式，一种是使用构造函数配合Start方法，另一种是使用静态方法Task.Run，后者是更常用的简化写法。
使用Task构造函数创建
先实例化Task对象，再调用Start方法启动任务，这种方式适合需要提前定义任务逻辑但不立即执行的场景。
using System;
using System.Threading.Tasks;
class Program
{
static void Main()
{
// 创建Task实例，传入要执行的方法
Task task1 = new Task(() =>
{
Console.WriteLine("Task1开始执行");
// 模拟耗时操作
System.Threading.Thread.Sleep(1000);
Console.WriteLine("Task1执行完成");
});
// 启动任务
task1.Start();
// 等待任务完成，避免主线程提前退出
task1.Wait();
Console.WriteLine("主线程执行结束");
}
}
使用Task.Run创建
Task.Run是更简洁的创建方式，它会自动将任务提交到线程池执行，不需要手动调用Start方法。
using System;
using System.Threading.Tasks;
class Program
{
static void Main()
{
// 直接创建并启动任务
Task task2 = Task.Run(() =>
{
Console.WriteLine("Task2开始执行");
System.Threading.Thread.Sleep(1500);
Console.WriteLine("Task2执行完成");
});
task2.Wait();
Console.WriteLine("主线程执行结束");
}
}
并行任务的执行与等待
要实现多个任务并行执行，只需要创建多个Task实例并启动，然后通过Task.WaitAll或者Task.WhenAll等待所有任务完成即可。
同步等待所有并行任务
使用Task.WaitAll会阻塞当前线程，直到所有传入的Task都执行完成。
using System;
using System.Threading.Tasks;
class Program
{
static void Main()
{
// 创建三个并行任务
Task taskA = Task.Run(() =>
{
Console.WriteLine("任务A开始执行");
System.Threading.Thread.Sleep(2000);
Console.WriteLine("任务A执行完成");
});
Task taskB = Task.Run(() =>
{
Console.WriteLine("任务B开始执行");
System.Threading.Thread.Sleep(1500);
Console.WriteLine("任务B执行完成");
});
Task taskC = Task.Run(() =>
{
Console.WriteLine("任务C开始执行");
System.Threading.Thread.Sleep(1000);
Console.WriteLine("任务C执行完成");
});
// 等待所有任务完成，总耗时约等于最长的单个任务耗时
Task.WaitAll(taskA, taskB, taskC);
Console.WriteLine("所有并行任务都执行完成");
}
}
异步等待所有并行任务
如果是在异步方法中，可以使用Task.WhenAll配合await关键字，不会阻塞当前线程，而是让出控制权等待任务完成。
using System;
using System.Threading.Tasks;
class Program
{
static async Task Main()
{
Task taskX = Task.Run(() =>
{
Console.WriteLine("任务X开始执行");
System.Threading.Thread.Sleep(1200);
Console.WriteLine("任务X执行完成");
});
Task taskY = Task.Run(() =>
{
Console.WriteLine("任务Y开始执行");
System.Threading.Thread.Sleep(1800);
Console.WriteLine("任务Y执行完成");
});
// 异步等待所有任务完成
await Task.WhenAll(taskX, taskY);
Console.WriteLine("异步等待后所有任务执行完成");
}
}
并行任务的异常处理
并行任务中如果抛出异常，不会直接抛到主线程，而是会聚合到AggregateException中，需要在等待任务时捕获处理。
using System;
using System.Threading.Tasks;
class Program
{
static void Main()
{
Task taskError = Task.Run(() =>
{
Console.WriteLine("异常任务开始执行");
throw new InvalidOperationException("并行任务执行出错");
});
try
{
// 等待任务时捕获异常
taskError.Wait();
}
catch (AggregateException ex)
{
// 遍历所有内部异常
foreach (var innerEx in ex.InnerExceptions)
{
Console.WriteLine($"捕获到异常：{innerEx.Message}");
}
}
}
}
并行任务的返回值处理
如果并行任务需要返回结果，可以使用Task<TResult>泛型类型，通过Result属性获取返回值，注意获取Result时会阻塞当前线程直到任务完成。
using System;
using System.Threading.Tasks;
class Program
{
static void Main()
{
// 创建带返回值的并行任务
Task<int> taskCalc1 = Task.Run(() =>
{
System.Threading.Thread.Sleep(1000);
return 10 + 20;
});
Task<int> taskCalc2 = Task.Run(() =>
{
System.Threading.Thread.Sleep(1500);
return 30 + 40;
});
// 等待所有任务完成
Task.WaitAll(taskCalc1, taskCalc2);
// 获取任务返回值
int result1 = taskCalc1.Result;
int result2 = taskCalc2.Result;
Console.WriteLine($"任务1结果：{result1}，任务2结果：{result2}，总和：{result1 + result2}");
}
}
并行任务使用的注意事项
- 不要创建过多并行任务，线程池的线程数量有限，过多的任务反而会导致性能下降，一般建议并行任务数量和CPU核心数相当。
- 如果并行任务中有共享资源的访问，需要做好线程同步，避免数据竞争问题，可以使用
lock关键字或者并发集合。 - 耗时的IO操作更适合使用Task的异步等待，而不是并行执行，避免占用线程池线程导致其他任务无法执行。