使用带有 Task.ContinueWith 的异步回调

Question

我正在尝试使用 C# 的 async/await/continuewith。 我的目标是必须有 2 个并行运行的任务，尽管哪个任务按顺序执行一系列动作。 为此，我计划有一个 List<Task> 代表并行运行的 2 个（或更多）任务，并在每个 Task 上使用 ContinueWith 我的问题是，await taskList 已经返回时，continue 中的回调似乎没有被执行。

为了总结，这里有一个示例来说明我期望发生的事情：

class Program
{
    static public async Task Test()
    {
        System.Console.WriteLine("Enter Test");
        await Task.Delay(100);
        System.Console.WriteLine("Leave Test");
    }

    static void Main(string[] args)
    {
        Test().ContinueWith(
        async (task) =>
        {
            System.Console.WriteLine("Enter callback");
            await Task.Delay(1000);
            System.Console.WriteLine("Leave callback");
        },
        TaskContinuationOptions.AttachedToParent).Wait();
        Console.WriteLine("Done with test");
    }
}

预期的输出是

Enter Test
Leave Test
Enter callback
Leave callback
Done with test

但是，输出是

Enter Test
Leave Test
Enter callback
Done with test

有没有办法让调用ContinueWith 的任务在被视为完成之前等待提供的函数完成？ IE。 .Wait 将等待两个任务完成，原始任务和 ContinueWith 返回的任务

Answer 1

在进行async 编程时，应努力将ContinueWith 替换为await，如下所示：

class Program
{
  static public async Task Test()
  {
    System.Console.WriteLine("Enter Test");
    await Task.Delay(100);
    System.Console.WriteLine("Leave Test");
  }

  static async Task MainAsync()
  {
    await Test();
    System.Console.WriteLine("Enter callback");
    await Task.Delay(1000);
    System.Console.WriteLine("Leave callback");
  }

  static void Main(string[] args)
  {
    MainAsync().Wait();
    Console.WriteLine("Done with test");
  }
}

使用await 的代码更简洁，更易于维护。

此外，您不应将父/子任务与async 任务一起使用（例如，AttachedToParent）。它们不是为协同工作而设计的。

Answer 2

我想添加我的答案来补充已被接受的答案。根据您尝试执行的操作，通常可以避免增加异步委托和包装任务的复杂性。例如，您的代码可以像这样重构：

class Program
{
    static async Task Test1()
    {
        System.Console.WriteLine("Enter Test");
        await Task.Delay(100);
        System.Console.WriteLine("Leave Test");
    }

    static async Task Test2()
    {
        System.Console.WriteLine("Enter callback");
        await Task.Delay(1000);
        System.Console.WriteLine("Leave callback");
    }

    static async Task Test()
    {
        await Test1(); // could do .ConfigureAwait(false) if continuation context doesn't matter
        await Test2();
    }

    static void Main(string[] args)
    {
        Test().Wait();
        Console.WriteLine("Done with test");
    }
}

Answer 3

当使用ContinueWith 方法链接多个任务时，您的返回类型将为Task<T>，而T 是传递给ContinueWith 的委托/方法的返回类型。

由于异步委托的返回类型是Task，您最终会得到Task<Task>，并最终等待异步委托返回Task，这是在第一个await 之后完成的.

为了纠正这种行为，您需要使用返回的Task，嵌入在您的Task<Task> 中。使用Unwrap扩展方法解压。