关于异步任务

Question

我有一个带有按钮和列表框的表单。我想将两个函数的结果添加到列表框中。这两个功能可能需要未知的时间才能完成，我想同时执行它们。只要其中一个函数完成计算，我想在列表框中显示结果（在另一个函数完成之前）。目前，两个功能完成后会显示结果。如果函数自己更新列表框，我不介意。

    async Task<string> LongTaskAsync()
    {
        for(int i = 0; i < 50; i++) {
            Thread.Sleep(100);
        }

        return "Completed long task async";
    }

    async Task<string> ShortTaskAsync()
    {
        for(int i = 0; i < 5; i++) {
            Thread.Sleep(100);
        }

        return "Completed short task async";
    }

    async void BtnRunClick(object sender, EventArgs e)
    {
        listBox1.Items.Clear();

        var longTask = Task.Run(() => LongTaskAsync());
        var shortTask = Task.Run(() => ShortTaskAsync());

        listBox1.Items.Add(await longTask);
        listBox1.Items.Add(await shortTask);        
    }

Answer 1

它同时显示其中 2 个的原因与您如何链接等待有关。

 listBox1.Items.Add(await longTask);
 listBox1.Items.Add(await shortTask); 

在较短的任务之前，您正在等待较长的任务。第二行在长时间任务完成后运行，较短的任务已经完成，这就是您同时看到它们的原因。但在一个您不知道执行哪些任务需要更长时间的世界中，您需要一个更好的解决方案。

  Action<Task<string>> continuationFunction = t => { this.listBox1.Items.Add(t.Result); };
  Task.Run(() => LongTaskAsync()).ContinueWith(continuationFunction, TaskScheduler.FromCurrentSynchronizationContext()); 
  Task.Run(() => ShortTaskAsync()).ContinueWith(continuationFunction, TaskScheduler.FromCurrentSynchronizationContext());

TaskScheduler.FromCurrentSynchronizationContext()是为了避免跨线程访问异常。

Answer 2

您不必为此使用ContinueWith。几乎总是可以避免混合async/await 和ContinueWith 风格的延续。在您的情况下，可以这样做：

async void BtnRunClick(object sender, EventArgs e)
{
    listBox1.Items.Clear();

    async Task longTaskHelperAsync() {
        // probably, Task.Run is redundant here,
        // could just do: var item = await LongTaskAsync();
        var item = await Task.Run(() => LongTaskAsync()); 
        listBox1.Items.Add(item);
    }

    async Task shortTaskHelperAsync() {
        // probably, Task.Run is redundant here, too
        var item = await Task.Run(() => ShortTaskAsync()); 
        listBox1.Items.Add(item);
    }

    await Task.WhenAll(longTaskHelperAsync(), shortTaskHelperAsync());
}

我相信这种方式更具可读性，您不必担心同步上下文、FromCurrentSynchronizationContext 等。

此外，如果在这些异步 ctask 仍在进行中时再次单击 BtnRunClick，您很可能需要处理可能的重新进入。

Answer 3

您可以通过创建一个等待任务的方法更通用地解决它，并将任务的结果添加到ListBox。

async Task ProcessAndAddToListAsync(Func<Task<string>> function)
{
    var value = await Task.Run(function); // Start the task in a background thread
    listBox1.Items.Add(value); // Update the control in the UI thread
}

然后在按钮点击事件的事件处理程序中使用这个方法：

async void BtnRunClick(object sender, EventArgs e)
{
    listBox1.Items.Clear();

    var longTask = ProcessAndAddToListAsync(LongTaskAsync);
    var shortTask = ProcessAndAddToListAsync(ShortTaskAsync);

    await Task.WhenAll(longTask, shortTask); // optional
    // Here do anything that depends on both tasks being completed
}