ASP.NET Core中如何将同步IO操作异步执行？（OpenXml场景）

我的ASP.NET Core应用使用Entity Framework Core，多数控制器方法为异步并调用EF Core的异步方法。但部分控制器方法需通过OpenXml读写Excel文件，这类IO操作理想状态应为异步，但OpenXml未提供异步方法，简化示例如下：

private async Task<model> ReadFromExcel()
{
    using var document = SpreadsheetDocument.Open("filePathAndName", false);

    // read data into model

    document.Close();

    context.Models.Add(newModel);
    await Context.SaveAsync();

    return newModel;
}

此外，我还需先在文件夹中查找文件，也希望实现异步：

Directory.EnumerateFiles("excelFolderName", ".xlsx");

根据《ASP.NET Core性能最佳实践》文档，不应使用Task.Run将同步API转为异步。我理解原因，但该规则是否适用于可能阻塞线程数秒的IO操作？是否应将这些IO操作异步化，若应如此，读写Excel文件及获取文件列表的最佳异步实现方式是什么？

关于Task.Run的适用场景 #

《ASP.NET Core性能最佳实践》不推荐用Task.Run包装同步API，核心是避免浪费线程池资源，但针对阻塞线程数秒的IO操作，这个规则可以灵活调整：

• ASP.NET Core依赖线程池处理请求，长时间阻塞线程会导致线程池耗尽，影响整体请求处理能力。这种场景下，用Task.Run把阻塞操作移到后台线程，能释放当前请求线程去处理其他请求，反而提升系统吞吐量。
• 若阻塞时间极短（如几毫秒），Task.Run的线程调度开销大于收益，就没必要使用。

文件列表枚举的异步实现 #

直接使用.NET 6及以上版本提供的原生异步API Directory.EnumerateFilesAsync，无需手动包装：

await foreach (var filePath in Directory.EnumerateFilesAsync("excelFolderName", "*.xlsx"))
{
    // 处理每个Excel文件
}

注意：搜索模式需写成*.xlsx，原代码的.xlsx缺少通配符会导致无法匹配文件。

Excel读写的异步实现 #

OpenXml本身无异步API，有两种可行方案：

方案1：用Task.Run包装同步操作 #

如果Excel读写确实会阻塞数秒，用Task.Run将这部分逻辑移到后台线程，同时保留EF Core的原生异步操作：

private async Task<Model> ReadFromExcel()
{
    var newModel = await Task.Run(() =>
    {
        using var document = SpreadsheetDocument.Open("filePathAndName", false);
        // 同步解析Excel数据到Model的逻辑
        document.Close();
        return parsedModel; // 返回解析完成的Model对象
    });

    context.Models.Add(newModel);
    await context.SaveChangesAsync();

    return newModel;
}

这种方式能避免长时间占用请求线程，适合高并发场景下的耗时IO操作。

方案2：替换为支持异步的Excel库 #

如果允许更换依赖库，选择原生支持异步IO的Excel处理库（如EPPlus 5.x及以上版本），示例代码：

private async Task<Model> ReadFromExcel()
{
    using var package = new ExcelPackage(new FileInfo("filePathAndName"));
    var worksheet = package.Workbook.Worksheets.First();
    
    // 异步读取单元格数据
    var cellValue = await worksheet.Cells["A1"].GetValueAsync<string>();
    
    var newModel = MapToModel(cellValue); // 将读取的数据映射为Model
    context.Models.Add(newModel);
    await context.SaveChangesAsync();
    
    return newModel;
}

这种方案是更理想的异步实现，无需依赖Task.Run，完全遵循异步IO设计原则。

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