将线程限制为数据库的最佳方法，同时允许更大的最大线程

Question

对 C# 相当陌生。我有 12 个 Oracle 数据库，每个数据库大约有 10000 多个模式。 我想在每个模式中运行一个多线程进程（比如查询或脚本）。

如果我：ThreadPool.SetMaxThreads(100,<not really sure what to put here>)，我很可能会立即使用 100 个连接访问 DB1。

我想一次将负载分散到每个 DB 最多 10 个线程/连接，但总体上可能有 100 个运行。我知道我不能拥有 ThreadPool1、Threadpool2 等。

最好的处理方法是什么？

任何见解表示赞赏！ --谢谢！

Answer 1

如果您松散地“启动” 100 个线程，那么对 ThreadPool 的设置将导致 100 个连接，并且这些线程几乎会立即开始针对您的数据库工作。

限制工作的并行线程数量的一种方法是使用 Parallel.ForEach 或 Parallel.For，因为它们提供了 ParallelOptions 参数，您可以在其中设置最大并行度：

Parallel.ForEach<string>(rows, new ParallelOptions() { MaxDegreeOfParallelism = batchSize},(row) => { 
     // your code here 
 } );

Parallel.For(0,100, new ParallelOptions() { MaxDegreeOfParallelism = batchSize }, i => { 
    //your code here 
});

MaxDegreeOfParallelism 会将并发工作限制为 batchSize 值，等待批处理完成后再开始新的批处理直到完成。