主页 / 问题 / 684868
Accepted
Rakzin Roman
Asked:2020-06-28 22:54:55 +0000 UTC2020-06-28 22:54:55 +0000 UTC

如何在 C# 中并行执行函数？

  • 772

当用户询问时，我想对数据库进行多次查询，然后显示响应。
但是如果我使用

async
await- Function1    
await- Function2  
await- Function3  
"склеить ответ функций и перевести в json"  
вывести ответ....

那么实际上这些函数是一个接一个地执行的，唯一的区别是直到没有答案时进程才会挂起，这与同步编程不同，但是没有多线程。
如何进行多线程处理，这就是从所有函数收到答案的时间 - 调用等待？

c#

2 个回答

  1. Best Answer

    尝试通过Task.WhenAll：

    Task first  = Function1();
Task second = Function2();
Task third  = Function3();

await Task.WhenAll(first, second, third);
    • 9

  2. 对于异步函数的并行执行，您需要使用方法Task.WhenAll()：

    var fooTask = FooAsync();
var barTask = BarAsync();
var gazTask = GazAsync();

await Task.WhenAll(fooTask, barTask, gazTask);

    所有任务完成后，可以使用awaitor 属性访问结果（如果有） Result：

    var fooResult = await fooTask;
var barResult = barTask.Result;
var gazResult = await gazTask;

    还值得一提的是异常处理。如果您不在每个方法中处理它们，那么Task.WhenAll()当然会将它们转发到顶部。特殊之处在于，如果Task.WhenAll()期望使用关键字，则发生的第一个异常会在顶部await抛出。在这种情况下，需要更加小心地处理任务：我们不知道哪些任务以错误结束，哪些任务还没有完成。因此，需要使用/属性进行初步检查。IsFaultedStatus

    var fooTask = FooAsync();
var barTask = BarAsync();
var gazTask = GazAsync();

try
{
    await Task.WhenAll(fooTask, barTask, gazTask);
}
catch (Exception e)
{
    if (fooTask.IsFaulted)
    {
        // ошибка в FooAsync()
    }
    else if (barTask.IsFaulted)
    {
        // ошибка в BarAsync()
    }
    else if (gazTask.IsFaulted)
    {
        // ошибка в GazAsync()
    }
}

    如果您执行阻塞等待 ( Task.WhenAll().Wait()) 或使用阻塞对应 ( Task.WaitAll())，则发生的所有异常都放在内部AggregateException。检查哪些任务已失败以及哪些任务尚未完成保持不变。

    • 3

相关问题