Блог

Довольно новичок в C #. У меня есть 12 баз данных Oracle, в каждой из которых более 10000 схем. Я хочу запустить многопоточный процесс (скажем, запрос или скрипт) для каждой схемы.

Если я: ThreadPool.SetMaxThreads(100,<not really sure what to put here>) , вполне вероятно, что я попаду в DB1 со 100 подключениями прямо из гейта.

Я хочу распределить эту нагрузку максимум до 10 потоков / подключений на базу данных одновременно, но с возможностью 100 запусков в целом. Я знаю, что у меня не может быть ThreadPool1, Threadpool2 и т.д.

Каков будет наилучший способ справиться с этим?

Любая информация приветствуется! —Спасибо!

Этот параметр для ThreadPool вызовет 100 подключений, если вы «запустите» 100 потоков свободно, и потоки начнут выполнять работу с вашей базой данных почти мгновенно.

Одним из способов ограничить количество параллельных потоков, выполняющих работу, является использование Parallel.ForEach или Parallel.Поскольку они предоставляют параметр 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, ожидая завершения пакета, прежде чем запускать новый до завершения.