如何结合Task.WhenAll使用NPoco的FetchAsync？遇触发时机问题求助

首先明确：调用FetchAsync时立即启动任务是异步并发的正常行为，这本身不是问题。你遇到的Task.WhenAll无法正常工作，核心原因是NPoco的Database实例（或你使用的scope对应的数据库上下文）不是线程安全的——同一个实例同时执行多个异步查询会引发资源冲突。

以下是可行的解决方案：

方案1：使用独立的数据库实例执行并发查询 #

为每个异步查询创建单独的Database实例（或对应的独立scope），避免共享实例导致的线程安全问题：

// 为每个查询创建独立的Database实例（根据你的连接字符串配置调整）
var classesTask = new Database("YourConnectionString").FetchAsync<ClassModel>();
var competitionsTask = new Database("YourConnectionString").FetchAsync<CompetitionDto>();

// 等待所有任务完成
await Task.WhenAll(classesTask, competitionsTask);

// 获取结果（任务已完成，用Result或await都可以）
var classes = classesTask.Result;
var competitions = competitionsTask.Result;

如果使用依赖注入，确保Database实例的生命周期配置为Transient（每次请求都创建新实例）。

方案2：放弃并发，改为串行执行（仅在必须共享scope时使用） #

如果业务逻辑要求必须使用同一个scope，只能放弃并发优势，改为逐个执行异步查询：

var classes = await scope.FetchAsync<ClassModel>();
var competitions = await scope.FetchAsync<CompetitionDto>();

方案3：排查具体异常信息 #

可以通过捕获异常定位问题细节，确认是否为线程安全或其他数据库连接问题：

try
{
    var classesTask = scope.FetchAsync<ClassModel>();
    var competitionsTask = scope.FetchAsync<CompetitionDto>();
    await Task.WhenAll(classesTask, competitionsTask);
    
    var classes = await classesTask;
    var competitions = await competitionsTask;
}
catch (Exception ex)
{
    // 输出异常信息，排查具体问题
    Console.WriteLine($"错误信息：{ex.Message}\n堆栈跟踪：{ex.StackTrace}");
}

内容的提问来源于stack exchange，提问作者Marko Marinkovic