У меня есть приложение .Net Core с реализацией Hangfire.
Существует повторяющееся задание в минуту, как показано ниже: -
RecurringJob.AddOrUpdate<IS2SScheduledJobs>(x => x.ProcessInput(), Cron.MinuteInterval(1));
var hangfireOptions = new BackgroundJobServerOptions
{
WorkerCount = 20,
};
_server = new BackgroundJobServer(hangfireOptions);
ProcessInput () внутренне проверяет BlockingCollection ()некоторых идентификаторов для обработки он продолжает непрерывную обработку.
Есть время, когда первые десять заданий ProcessInput () продолжают обрабатываться с 10 работниками, когда другие новые задания ProcessInput () ставятся в очередь.
Для этой цели я хотел увеличить количество рабочих, скажем, примерно до 50, чтобы параллельно обрабатывалось 50 заданий ProcessInput ().
Пожалуйста, предложите.Спасибо.