等待完成异步 lambda 表达式中的所有异步方法

debugcn 发表于 Dev

Arunprasanth KV

我有一个像下面这样的方法

internal static ProgressDialogResult Execute(Window owner, string label, Action operation, ProgressDialogSettings settings)
{
    return ExecuteInternal(owner, label, (object)operation, settings);
}

用于显示基于任务完成的进度条。我正在调用上面的方法，如下所示

int count = soilData.Count;

var result = ProgressDialog.Execute(this, "Loading data", async () => {
      for (int i = 1; i <= count; i = i + 1000)
      {
         await soilDataMigration.MigrateSoilData(soilData.GetRange(i, i + 1000 >= count ? count - i : 1000));    
      }
   }, ProgressDialogSettings.WithSubLabel);

if (result.OperationFailed)
   MessageBox.Show("Soil data upload failed failed.");
else
   MessageBox.Show("Soil data successfully executed.");
soilData.Clear();

但是当我尝试执行它时，它突然从 lambda 中出来并开始执行 if 语句。但是我的预期行为是只有当我的所有异步操作在 loop 内完成时，控制才会离开这个 lambda。

我已经在 stackoverflow 中检查了这个问题有没有办法同步运行 async lambda？

但不幸的是，该软件包与 .net 版本 4.5.2 不兼容

有人可以帮我解决这个问题吗？

扎茨曼

实际上，您有两种选择：1）重构所有调用以使其async..await兼容，例如

internal static async System.Threading.Task<ProgressDialogResult> Execute(Window owner, string label, Func<System.Threading.Task> operation, ProgressDialogSettings settings)
{
    return await ExecuteInternal(owner, label, (object)operation, settings);
}

internal static async System.Threading.Task<ProgressDialogResult> ExecuteInternal(Window owner, string label, Func<System.Threading.Task> operation, ProgressDialogSettings settings)
{
    // do whatever
    await operation();
    return //whatever;
}

然后像这样消费它：

int count = soilData.Count;

var result = await ProgressDialog.Execute(this, "Loading data", async () => {
      for (int i = 1; i <= count; i = i + 1000)
      {
         await soilDataMigration.MigrateSoilData(soilData.GetRange(i, i + 1000 >= count ? count - i : 1000));    
      }
   }, ProgressDialogSettings.WithSubLabel);

if (result.OperationFailed)
   MessageBox.Show("Soil data upload failed failed.");
else
   MessageBox.Show("Soil data successfully executed.");
soilData.Clear();

和 2) 只需将await您传递的方法更改为soilDataMigration.MigrateSoilData(soilData.GetRange(i, i + 1000 >= count ? count - i : 1000)).GetAwaiter().GetResult();

一般来说，选项 1) 更好，因为它清楚地表示意图并协调您拥有的代码。选项 2) 更像是一种解决方法。

本文收集自互联网，转载请注明来源。

如有侵权，请联系[email protected] 删除。