发生异常时如何中断Task链？

Question

我创造了作品链。他们将在我的附加线程中工作。为此，我使用Task。另外，如果发生任何异常，我想中断链的工作并将其抛出到调用线程中。但我看到我的链没有断，act2 和act3 也完成了。

我该如何解决？

using System;
using System.Threading.Tasks;

namespace Bushman.Sandbox.Threads {
    class Program {
        static void Main(string[] args) {
            Console.Title = "Custom thread";

            try {
                // First work
                Action act1 = () => {
                    for (int i = 0; i < 5; i++) {

                        // I throw the exeption here
                        if (i == 3) throw new Exception("Oops!!!");

                        Console.WriteLine("Do first work");
                    }
                };

                // Second work
                Action act2 = () => {
                    for (int i = 0; i < 5; i++)
                        Console.WriteLine("  Do second work");
                };

                // Third work
                Func<int> act3 = () => {
                    for (int i = 0; i < 5; i++)
                        Console.WriteLine("    Do third work");
                    return 12345;
                };

                Task task = new Task(act1);

                // Build the chain of the works
                var awaiter = task.ContinueWith(_ => act2(),
                    TaskContinuationOptions.ExecuteSynchronously)
                    .ContinueWith(_ => act3(),
                    TaskContinuationOptions.ExecuteSynchronously)
                    .GetAwaiter();

                Console.WriteLine("Work started...");

                // launch the chain
                task.Start();

                // Here I get some result
                int result = awaiter.GetResult(); // 12345

                if (task.IsCanceled || task.IsFaulted) {
                    throw task.Exception.InnerException;
                }

                Console.WriteLine("The result: {0}",
                    result.ToString());
            }
            catch (Exception ex) {
                Console.ForegroundColor = ConsoleColor.Red;
                Console.WriteLine(ex.Message);
                Console.ResetColor();
            }

            Console.WriteLine("Press any key for exit...");
            Console.ReadKey();
        }
    }
}

Answer 1

您必须使用 NotOnFaulted 任务继续选项。

由于TaskContinuationOptions 被Flags 属性修饰，您可以将NotFaulted 与其他选项结合使用。

 var awaiter = task.ContinueWith(_ => act2(),
                TaskContinuationOptions.ExecuteSynchronously | TaskContinuationOptions.NotOnFaulted)
                .ContinueWith(_ => act3(),
                TaskContinuationOptions.ExecuteSynchronously | TaskContinuationOptions.NotOnFaulted)
                .GetAwaiter();

即使您使用 async/await 关键字，这种方法仍然有效（但您摆脱了 GetAwaiter 调用）

Answer 2

代码试图以非常规的方式使用任务，几乎就像它们是线程一样。它们不是 - 任务是一项将被安排在线程池线程上运行的作业，而不是线程本身。调用Task.Start 不会执行任何操作，它会安排其委托在线程上运行。这就是为什么从不使用构造函数创建任务的原因。

启动和协调任务最简单的方法是使用Task.Run和async/await，例如：

public static async Task<int> MyMethodAsync()
{
    try
    {
        await Task.Run(()=>act1());
        await Task.Run(()=>act2());
        var result=await Task.Run(()=>act3());
        return result;
    }
    catch (Exception exc)
    {
           //Do something
    }
}

您不能在控制台应用程序的 Main 函数中使用 async/await，因此您必须按以下方式调用该方法：

var result=MyMethodAsync().Result;

在任务上调用 .Wait() 或 .Result 会重新引发其中引发的任何异常。

如果没有async/await，您需要使用ContinueWith 并实际检查上一个任务的结果。如果你只是想停止处理，你可以通过 TaskContinuationOptions.NotOnFaulted ：

var result = Task.Run(()=>act1())
                 .ContinueWith( t1=>act2(),TaskContinuationOptions.NotOnFaulted)
                 .ContinueWith( t2=>act3(),TaskContinuationOptions.NotOnFaulted)
                 .Result;

您不需要显式访问等待者。对.Result 的最终调用将返回整数结果，或者如果先前的任务之一出错则抛出AggregateException