0

我正在开发一个 Windows 服务,我有两个相互依赖的相关调用,我想为每个“对”或“一组”调用异步运行。有几种方法可以做到这一点,我尝试了几种不同的方法并解决了这个问题,因为使用一个代码块来处理比两个单独的块具有自己的等待Task.WhenAll()调用更方便。在我的测试中,这似乎按预期工作,但我以前从未像这样将两个任务链接在一起,我想知道这是否是一个好方法,是否可能有更合适的方法来获得相同的结果(单个代码块)。

这就是我所拥有的。这看起来像是一种合理的链接任务的方式吗?如果不是,请告诉我原因。

提前致谢。-坦率

//get all pending batches
foreach (string batchId in workload)
{
    try
    {
        // I am using this ContinueWith pattern here to aggregate the Tasks
        // which makes it more convenient to handle exceptions in one place
        Task t = bll.GetIncomingBatchAsync(batchId).ContinueWith(
            task => bll.SaveIncomingBatchAsync(task.Result),
            TaskContinuationOptions.OnlyOnRanToCompletion);

        saveBatchTasks.Add(t);
    }
    catch (Exception ex)
    {
        _logger.WriteError(ex, "ProcessWorkloadAsync error building saveBatchTasks!");
        throw ex;
    }
}

try
{
    await Task.WhenAll(saveBatchTasks);
}
catch (Exception ex)
{
    _logger.WriteError(ex, "ProcessWorkloadAsync error executing saveBatchTasks!");
    throw ex;
}
4

2 回答 2

3

不,你不应该使用ContinueWith. 改为使用await

如果您担心跨两个函数分离逻辑,只需使用本地函数:

//get all pending batches
foreach (string batchId in workload)
{
  try
  {
    async Task GetAndSave()
    {
      var result = await bll.GetIncomingBatchAsync(batchId);
      await bll.SaveIncomingBatchAsync(result);
    }

    saveBatchTasks.Add(GetAndSave());
  }
  catch (Exception ex)
  {
    _logger.WriteError(ex, "ProcessWorkloadAsync error building saveBatchTasks!");
    throw ex;
  }
}
于 2020-05-20T20:09:29.383 回答
1

通常不建议将老式ContinueWith方法与 async/await 结合使用,因为后者是为了取代前者而发明的。如果需要,您可以使用LINQ在一行中创建任务:

Task[] saveBatchTasks = workload.Select(async batchId =>
{
    var result = await bll.GetIncomingBatchAsync(batchId);
    await bll.SaveIncomingBatchAsync(result);
}).ToArray();

await Task.WhenAll(saveBatchTasks);
于 2020-05-20T20:22:59.630 回答