Task.Start 奇怪的行为

Question

您好，我有以下创建任务的代码。然后将其设置为启动。 该任务旨在向ConcurrentBag 列表添加响应。 但是 await 似乎并没有等待所有任务完成。但它们被标记为已完成。列表中只有一项任务。 使用Task.Run时效果很好！

public async void RunT1()
{          
    DoesNotWork();
}

public async void RunT2()
{          
    DoesWork();
}

public async void DoesNotWork()
{
    ConcurrentBag<string> concurrentBag = new ConcurrentBag<string>();
    List<Task> taskList = new List<Task>();

    Task task1 = new Task(async () =>
    {
        var xml = await LongWorkingMethod();
        concurrentBag.Add(xml);
    });

    taskList.Add(task1);

    taskList[0].Start();
    await Task.WhenAll(taskList);

    if (concurrentBag.Count > 0) //concurrentBag is empty,
        //even though the task has finished
    {
        Debug.Print("success");
    }
}

public async void DoesWork()
{
    ConcurrentBag<string> concurrentBag = new ConcurrentBag<string>();
    List<Task> taskList = new List<Task>();

    Task task1 = Task.Run(async () =>
    {
        var xml = await LongWorkingMethod();
        concurrentBag.Add(xml);
    });

    taskList.Add(task1);

    await Task.WhenAll(taskList);

    if (concurrentBag.Count > 0) //concurrentBag is NOT empty
    {
        Debug.Print("success");
    }
}

Answer 1

几乎没有理由直接使用Task 构造函数。

在您的情况下，Task 构造函数不支持async 委托（即Action 而不是Func<Task>），当您将一个作为参数传递时，它被视为async void。

这意味着调用Start “触发并忘记”委托并且它不能等待其中的异步操作完成，因为没有Task到await。

var task = new Task(async () => await Task.Delay(1000));
task.Start();
await task; // completes immediately

如果您需要运行新的Task，请使用Task.Run。如您所见，Task.Run 确实支持 async 委托并等待整个操作完成

var task = Task.Run(async () => await Task.Delay(1000));
await task; // completes after 1000 milliseconds