如何结合DbContext连接池大小确定Parallel.ForEachAsync的并行度？

我在查阅了Parallel.ForEach中管理非线程安全DbContext数据库连接的相关文档后，想知道有没有办法结合Web服务器资源和DbContext最大连接池大小，合理设置MaxDegreeOfParallelism属性，避免在迭代数千条记录时给数据库造成过大压力；或者是不是在当前场景下根本不需要管理这个属性？

我的迭代代码如下：

public async Task<T> DoThings()
{
    HashSet<FruizioneDto> theList = // get items;
    
    DbContextOptionsBuilder<WebinarDbContext> builder = new();
    builder.UseLazyLoadingProxies();
    builder.UseSqlServer(Environment.GetEnvironmentVariable("ConnectionString"));
    PooledDbContextFactory<WebinarDbContext> factory = new(options: builder.Options, poolSize: 1024); // <- 1024是PooledDbContext的默认值

    ParallelOptions parallelOptions = new() { MaxDegreeOfParallelism = -1 }; // -1表示全速运行
    await Parallel.ForEachAsync(theList, parallelOptions, async (fruizione, cancellationToken) =>
    {
        using WebinarDbContext context = factory.CreateDbContext();
        using (IDbContextTransaction transaction = context.Database.BeginTransaction())
        {
            try
            {
                // 一些业务逻辑...
        
                transaction.Commit();
            }
            catch (FunctionBusinessLogicException ex)
            {
                transaction.Rollback();

                // 一些异常处理...

                return;
            }
            catch (Exception ex)
            {
                transaction.Rollback();

                // 一些异常处理...
                return;
            }
        }
    }

   return T;
}

循环内的操作是为完成课程的用户生成PDF证书并更新数据库记录。theList是包含用户及所修课程信息的FruizioneDto集合，具体操作包括计算课程有效学分、替换HTML模板生成PDF并上传至Azure存储账户，操作顺利的话就更新Fruizione表并新增证书记录。

请问有没有办法确定并行度和DbContext最大连接池大小的合理匹配方式？

首先明确：你必须管理MaxDegreeOfParallelism，设置为-1会让并行任务数不受限制，极大概率打满数据库连接池，甚至压垮Web服务器资源。

并行度与连接池的匹配逻辑 #

• 核心原则：并行度不能超过数据库连接池的可用连接数，同时要结合Web服务器CPU核心数——你的任务是CPU（PDF生成）+ IO（数据库、Azure上传）混合操作，得兼顾两类资源的承载能力。

  • 数据库连接池默认大小（SQL Server）是100，你设置的1024远大于默认值，实际要以数据库实例允许的最大连接数为准，过度设置连接池只会浪费资源。
  • 混合任务场景下，并行度建议设为CPU核心数的1.5~2倍，同时不能超过数据库连接池可用数的80%（留余量给其他业务请求）。

• 具体计算方式

  1. 获取服务器CPU核心数：Environment.ProcessorCount
  2. 取数据库连接池大小（或数据库实例最大连接数）的80%作为可用连接上限
  3. 最终MaxDegreeOfParallelism取上述两个值的较小值。比如8核服务器+数据库可用连接数80，并行度设为12~16；如果数据库可用连接数仅10，并行度最多设为10。

代码调整建议 #

• 不要硬编码poolSize为1024，除非你确认数据库能支撑这么多连接，保持默认或根据数据库配置调整即可。
• 动态计算并行度：

int cpuCount = Environment.ProcessorCount;
// 替换为你的数据库实例实际允许的最大连接数，比如SQL Server默认100
int maxDbConnections = Math.Min(100, 数据库实例最大连接数); 
int availableDbConnections = (int)(maxDbConnections * 0.8);
int recommendedParallelism = Math.Min((int)(cpuCount * 1.5), availableDbConnections);

ParallelOptions parallelOptions = new() 
{ 
    MaxDegreeOfParallelism = recommendedParallelism 
};

额外注意事项 #

• 观察服务器CPU、内存使用率，通过压测找到最优并行度——PDF生成会占用大量CPU，Azure上传是IO密集操作，两者的资源消耗都会影响并行任务的承载量。
• 确保每个并行任务里的DbContext都用using包裹，PooledDbContextFactory会自动复用DbContext，无需手动管理连接释放。
• 若迭代记录数过万，建议分批次处理，避免一次性占用过多资源。

内容的提问来源于stack exchange，提问作者Matteo Pietro Peru