145

有人可以在下面的示例中解释是否await和ContinueWith是否是同义词。我第一次尝试使用 TPL 并且一直在阅读所有文档，但不了解其中的区别。

等待：

String webText = await getWebPage(uri);
await parseData(webText);

继续：

Task<String> webText = new Task<String>(() => getWebPage(uri));
Task continue = webText.ContinueWith((task) =>  parseData(task.Result));
webText.Start();
continue.Wait();

在特定情况下，一个优先于另一个吗？

4

2 回答 2

128

这是我最近用来说明差异和使用异步解决的各种问题的代码片段序列。

假设您的基于 GUI 的应用程序中有一些需要花费大量时间的事件处理程序，因此您希望使其异步。这是您开始的同步逻辑：

while (true) {
    string result = LoadNextItem().Result;
    if (result.Contains("target")) {
        Counter.Value = result.Length;
        break;
    }
}

LoadNextItem返回一个任务，最终会产生一些你想要检查的结果。如果当前结果是您要查找的结果，则更新 UI 上某个计数器的值，然后从该方法返回。否则，您将继续处理来自 的更多项目LoadNextItem。

异步版本的第一个想法：只使用延续！让我们暂时忽略循环部分。我的意思是，可能会出什么问题？

return LoadNextItem().ContinueWith(t => {
    string result = t.Result;
    if (result.Contains("target")) {
        Counter.Value = result.Length;
    }
});

太好了，现在我们有了一个不会阻塞的方法！它反而崩溃了。UI 控件的任何更新都应该发生在 UI 线程上，因此您需要考虑到这一点。值得庆幸的是，有一个选项可以指定应如何安排延续，并且有一个默认选项：

return LoadNextItem().ContinueWith(t => {
    string result = t.Result;
    if (result.Contains("target")) {
        Counter.Value = result.Length;
    }
},
TaskScheduler.FromCurrentSynchronizationContext());

太好了，现在我们有了一个不会崩溃的方法！它会默默地失败。继续任务本身是独立的任务，它们的状态与先前任务的状态无关。因此，即使出现LoadNextItem故障，调用者也只会看到已成功完成的任务。好的，那么只需传递异常，如果有的话：

return LoadNextItem().ContinueWith(t => {
    if (t.Exception != null) {
        throw t.Exception.InnerException;
    }
    string result = t.Result;
    if (result.Contains("target")) {
        Counter.Value = result.Length;
    }
},
TaskScheduler.FromCurrentSynchronizationContext());

太好了，现在这确实有效。对于单个项目。现在，那个循环怎么样。结果，与原始同步版本的逻辑等效的解决方案将如下所示：

Task AsyncLoop() {
    return AsyncLoopTask().ContinueWith(t =>
        Counter.Value = t.Result,
        TaskScheduler.FromCurrentSynchronizationContext());
}
Task<int> AsyncLoopTask() {
    var tcs = new TaskCompletionSource<int>();
    DoIteration(tcs);
    return tcs.Task;
}
void DoIteration(TaskCompletionSource<int> tcs) {
    LoadNextItem().ContinueWith(t => {
        if (t.Exception != null) {
            tcs.TrySetException(t.Exception.InnerException);
        } else if (t.Result.Contains("target")) {
            tcs.TrySetResult(t.Result.Length);
        } else {
            DoIteration(tcs);
        }});
}

或者，您可以使用async执行相同的操作，而不是上述所有操作：

async Task AsyncLoop() {
    while (true) {
        string result = await LoadNextItem();
        if (result.Contains("target")) {
            Counter.Value = result.Length;
            break;
        }
    }
}

现在好多了，不是吗？

于 2013-09-24T13:10:16.563 回答
120

在第二个代码中，您正在同步等待继续完成。await在第一个版本中，该方法将在遇到第一个尚未完成的表达式时立即返回给调用者。

它们非常相似，因为它们都安排了一个延续，但是一旦控制流变得稍微复杂，就会await导致更简单的代码。此外，正如 Servy 在评论中所指出的，等待任务将“解包”聚合异常，这通常会导致更简单的错误处理。此外 usingawait将隐式安排调用上下文中的延续（除非您使用ConfigureAwait）。没有什么是不能“手动”完成的，但使用await.

await我建议您尝试使用两者来实现稍大的操作序列Task.ContinueWith- 它可以真正让您大开眼界。

于 2013-09-23T17:26:59.527 回答