parallel-processing - .Net Core Hangfire - 增加 worker 数量

Question

我有一个带有 Hangfire 实现的 .Net Core 应用程序。

每分钟有一个重复的工作如下:-

RecurringJob.AddOrUpdate<IS2SScheduledJobs>(x => x.ProcessInput(), Cron.MinuteInterval(1));

var hangfireOptions = new BackgroundJobServerOptions
            {
                WorkerCount = 20,
            };
            _server = new BackgroundJobServer(hangfireOptions);

ProcessInput() 内部会检查一些要处理的 Id 的 BlockingCollection()，它会不断地处理。

有一段时间，前十个 ProcessInput() 作业继续处理 10 个 worker ，而其他新的 ProcessInput() 作业被排入队列。

为此，我想增加工作人员的数量，比如大约 50 个，以便并行处理 50 个 ProcessInput() 作业。

请提出建议。谢谢。

Answer 1

在 .NET Core 版本中，您可以在添加 Hangfire Server 时设置工作人员数量:

services.AddHangfireServer(options => options.WorkerCount = 50);