当前位置：首页 > news >正文

C#中TaskFactory实现线程任务

news 2026/6/15 6:33:53

在 C# 中，TaskFactory是System.Threading.Tasks命名空间下的一个类，它为任务的创建、管理和调度提供了一个简便的方式。与直接使用Task类相比，TaskFactory提供了更高层次的抽象，允许开发者更加灵活地控制任务的创建、执行、取消、调度等操作。

1.TaskFactory的基本概念

TaskFactory是一个帮助你创建和管理任务的工具类。它通过封装Task的创建过程，使得任务的启动、调度和继续等操作变得更加方便和灵活。

主要功能和用途

任务创建和启动：通过StartNew方法创建并启动新的任务。
任务调度控制：允许通过指定TaskCreationOptions和TaskContinuationOptions来控制任务的行为。
任务的链式操作：支持在一个任务完成后自动执行其他任务。
支持取消任务：可以结合CancellationToken来控制任务的取消。
处理异常：能够在任务异常时进行处理。

2.TaskFactory的基本功能

任务创建与启动 (StartNew)

TaskFactory提供了StartNew方法来创建并启动任务。这是其最常用的功能，它允许你异步执行一个委托（通常是一个Action或Func）。

var factory =newTaskFactory();

Task task = factory.StartNew(() => {

Console.WriteLine("任务开始执行...");

});

在这个例子中，StartNew会启动一个新任务，并异步执行提供的委托。

任务选项控制：TaskCreationOptions

TaskFactory允许你通过TaskCreationOptions来定制任务的创建方式。你可以指定任务的执行方式、优先级等。

常见的选项包括：

None：默认选项，任务使用线程池线程执行。
LongRunning：表示任务可能需要长时间执行，通常会分配一个新的线程来执行任务，而不是使用线程池。
AttachedToParent：指示任务是父任务的一部分。
DenyChildAttach：阻止子任务附加到父任务。

var factory =newTaskFactory(TaskCreationOptions.LongRunning, TaskContinuationOptions.None);

Task task = factory.StartNew(() => {

Console.WriteLine("长时间运行的任务");

});

任务链式操作：ContinueWith和TaskContinuationOptions

TaskFactory允许你创建任务的链式操作，也就是一个任务完成后可以自动执行另一个任务。你可以使用ContinueWith来设置后续任务，并通过TaskContinuationOptions控制后续任务的执行条件。

例如，你可以让任务只在当前任务成功完成时执行后续任务，或者只在任务失败时执行后续任务。

Task task1 = factory.StartNew(() => {

Console.WriteLine("任务1");

});

Task task2 = task1.ContinueWith(t => {

Console.WriteLine("任务2（在任务1完成后执行）");

}, TaskContinuationOptions.OnlyOnRanToCompletion);

任务取消：CancellationToken

TaskFactory可以与CancellationToken配合使用，以便支持任务取消。当你需要取消一个任务时，CancellationTokenSource发出取消请求，Task会检查该请求并在合适的时机停止执行。

var cts =newCancellationTokenSource();

var factory =newTaskFactory();

Task task = factory.StartNew(() => {

for(inti = 0; i < 10; i++) {

if(cts.Token.IsCancellationRequested) {

Console.WriteLine("任务已取消");

return;

}

Console.WriteLine("任务正在执行...");

Thread.Sleep(1000);

}

}, cts.Token);

// 取消任务

cts.Cancel();

任务异常处理

TaskFactory还支持任务的异常处理。如果任务在执行过程中发生异常，你可以通过ContinueWith捕获并处理这些异常。

Task task = factory.StartNew(() => {

thrownewInvalidOperationException("发生错误");

}).ContinueWith(t => {

if(t.Exception !=null) {

Console.WriteLine($"任务发生了异常: {t.Exception.Message}");

}

}, TaskContinuationOptions.OnlyOnFaulted);

在这个例子中，ContinueWith会在任务发生异常时被调用，并处理异常信息。

3.TaskFactory的实现原理与机制

TaskFactory本质上是对Task类的封装，它通过TaskCreationOptions和TaskContinuationOptions提供了更灵活的任务调度和管理方式。

内部工作机制

任务创建和启动：TaskFactory提供的方法（如StartNew）会创建一个Task实例，并将任务的执行逻辑传递给Task。
任务调度：TaskFactory可以通过不同的任务选项来控制任务的调度方式，例如将任务标记为长时间运行的任务。
任务链式操作：ContinueWith和TaskContinuationOptions使得开发者能够创建任务之间的依赖关系，并定义任务完成后的后续动作。
任务取消：任务的取消是通过CancellationToken实现的。开发者可以通过传递CancellationToken来允许任务在某个条件下提前终止。