卡在异步等待线程中

Question

在构造函数中我想调用一种方法类型：

private async Task OnLoadPrometDanKorisnikDatum

我想在它完成时等待那个方法，我有更多这样的方法（3），我想在后台线程中调用这 3 个方法，不要等他完成，只想等待第一个方法.我想让他们并行执行。 我有方法异步任务，在视图模型的构造函数中我这样调用

OnLoadPrometDanKorisnikDatum(KorisnikID, PomocnaDnDDatnaDat, 
    DatumVrednost).Wait();
OnLoadPrometNedelja(KorisnikID, PomocnaDnDDatnaDatNedelja).Wait();

如果我没有将 .Wait() 放在最后，程序将无法运行。我在调试模式下看到它们异步运行，但花费的时间告诉我它们是子（一种方法时间 + 第二种方法时间 + ....）。 有人可以帮帮我吗，这对我来说很重要......

Answer 1

回答

处理您的场景的最佳方法是使用async void。

我建议首先阅读下面的Explanation 部分，以充分了解async void 的最佳实践。

public MyConstructor()
{
    ExecuteAsyncMethods();
}

async void ExecuteAsyncMethods()
{ 
    try
    {
        await OnLoadPrometDanKorisnikDatum(KorisnikID, PomocnaDnDDatnaDat, DatumVrednost);
        await OnLoadPrometNedelja(KorisnikID, PomocnaDnDDatnaDatNedelja);
    }
    catch(Exception e)
    {
        //Handle Exception
    }
}

说明

许多 C# 开发人员都被教导“永远不要使用 async void”，但这是它为数不多的用例之一。

是的 async void 可能很危险，原因如下：

• 不能await 和async avoid 方法
• 可能导致竞争条件
• 难以捕捉由async void 方法抛出的Exception
  • 例如以下try/catch 块不会捕获此处抛出的Exception：

public MyConstructor()
{
    try
    {
        //Cannot await `async void`
        AsyncVoidMethodWithException();
    }
    catch(Exception e)
    {
        //Will never catch the `Exception` thrown in  `AsyncVoidMethodWithException` because `AsyncVoidMethodWithException` cannot be awaited
    }

    //code here will be executing by the time `AsyncVoidMethodWithException` throws the exception
}

async void AsyncVoidMethodWithException()
{
    await Task.Delay(2000);
    throw new Exception();
}

话虽如此，只要我们将整个 async void 的内容包装在一个 try/catch 块中，我们就能够捕获异常，如下所示：

public MyConstructor()
{
    AsyncVoidMethodWithException();
}

async void AsyncVoidMethodWithException()
{
    try
    {
        await Task.Delay(2000);
        throw new Exception();
    }
    catch(Exception e)
    {
        //Exception will be caught and successfully handled 
    }
}

SafeFireAndForget

我创建了一个库来帮助解决这个问题，它的额外好处是它避免了编写可能被未来开发人员滥用的async void 代码。

它是开源的，也可以在 NuGet 上使用：

• Source Code
• NuGet Package

SafeFireAndForget

SafeFireAndForget 允许我们安全地执行Task，同时不会阻塞调用线程，也无需等待它完成后再移动到下一行代码。

下面是SafeFireAndForget 的简化版本，您可以将其添加到您的项目中。

但是，我建议将其 complete source code 复制/粘贴或将其 NuGet Package 添加到您的库中以获得更强大的实现

public static async void SafeFireAndForget<TException>(this Task task, Action<TException> onException = null, bool continueOnCapturedContext = false) where TException : Exception
{
    try
    {
        await task.ConfigureAwait(continueOnCapturedContext);
    }
    catch (TException ex) when (onException != null)
    {
        onException(ex);
    }
}

使用 SafeFireAndForget

要使用SafeFireAndForget，请将其附加到您的方法调用中，如下所示：

OnLoadPrometDanKorisnikDatum(KorisnikID, PomocnaDnDDatnaDat, DatumVrednost).SafeFireAndForget();
OnLoadPrometNedelja(KorisnikID, PomocnaDnDDatnaDatNedelja).SafeFireAndForget();

要处理由Task 抛出的任何Exception，请使用onException。这是一个将Exception 打印到调试控制台的示例：

OnLoadPrometDanKorisnikDatum(KorisnikID, PomocnaDnDDatnaDat, DatumVrednost).SafeFireAndForget(ex => Debug.WriteLine(ex));
OnLoadPrometNedelja(KorisnikID, PomocnaDnDDatnaDatNedelja).SafeFireAndForget(ex => Debug.WriteLine(ex));