在 iprocess 完成之前等待继续

Question

我创建了一个运行 X 个线程的自定义工厂。我的问题是我希望我的 ContinueWiths 在等待之后执行代码之前完成。

调用代码：

Task t = _manager.RunCalcsCustomFactory(int.Parse(textTasksToCreate.Text), int.Parse(textMaxThreads.Text), cancelSource.Token, new Progress<string>(UpdateStatus), new Progress<int>(UpdateProgress));

Task errorHandlingTask = t.ContinueWith((tt) => ProcessError(), TaskContinuationOptions.OnlyOnFaulted);
Task cancelTask = t.ContinueWith((tttt) => TasksComplete(), TaskContinuationOptions.OnlyOnCanceled);
await Task.WhenAll(t);

UpdateStatus("Done");

在我的任务中，我立即抛出一个错误。所以我希望我的 ProcessError 在执行 UpdateStatus("Done") 之前完成。

这是我的输出：

start thread10
Waiting for tasks to finish.
Exception: Too many connections open.
Done
Error: Too many connections open.
ERROR

如果在 RunCalcsCustomFactory 中的 UpdateStatus("Error: Too many connections open.") 之前显示并且 UpdateStatus("ERROR") 在 ProcessError 中运行，请注意完成。

我希望 UpdateStatus("Done") 在 RunCalcsCustomFactory 的回调完成并且 ProcessError 完成后运行。

Answer 1

只要您的代码中有ContinueWith，您就应该改用async/await：

try
{
  await _manager.RunCalcsCustomFactory(int.Parse(textTasksToCreate.Text), int.Parse(textMaxThreads.Text), cancelSource.Token, new Progress<string>(UpdateStatus), new Progress<int>(UpdateProgress));
}
catch (OperationCanceledException)
{
  TasksComplete();
}
catch (Exception ex)
{
  ProcessError();
}

UpdateStatus("Done");