.NET6 Worker Service多IHostedService StopAsync同步执行致停机耗时过长

问题原因 #

.NET Host默认对注册的IHostedService实例，在停机时会按注册顺序依次调用StopAsync方法，并且会等待前一个服务的StopAsync执行完成后，才会调用下一个服务的StopAsync。这就导致当你注册几十个Worker时，停机时间是所有Worker停机逻辑的耗时累加，很容易触发systemd等服务管理工具的超时限制。

解决方案 #

通过自定义一个并行托管服务执行器，替代默认的顺序执行逻辑，实现所有Worker的StartAsync和StopAsync并行调用。

1. 实现并行托管服务执行器 #

创建一个ParallelHostedServiceExecutor类，统一管理所有BackgroundService实例，并行处理启动和停止逻辑：

using Microsoft.Extensions.Hosting;
using Microsoft.Extensions.Logging;
using System.Collections.Generic;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;

public class ParallelHostedServiceExecutor : IHostedService
{
    private readonly IEnumerable<BackgroundService> _workerServices;
    private readonly ILogger<ParallelHostedServiceExecutor> _logger;
    private List<Task> _runningWorkerTasks = new();

    public ParallelHostedServiceExecutor(IEnumerable<BackgroundService> workerServices, ILogger<ParallelHostedServiceExecutor> logger)
    {
        _workerServices = workerServices;
        _logger = logger;
    }

    public async Task StartAsync(CancellationToken cancellationToken)
    {
        _logger.LogInformation("启动所有Worker服务（并行模式）");
        _runningWorkerTasks = _workerServices.Select(worker => worker.StartAsync(cancellationToken)).ToList();
        await Task.WhenAll(_runningWorkerTasks).ConfigureAwait(false);
    }

    public async Task StopAsync(CancellationToken cancellationToken)
    {
        _logger.LogInformation("停止所有Worker服务（并行模式）");
        var stopTasks = _workerServices.Select(worker => worker.StopAsync(cancellationToken)).ToList();
        await Task.WhenAll(stopTasks).ConfigureAwait(false);
    }
}

2. 修改服务注册逻辑 #

在Program.cs中，将所有Worker注册为BackgroundService（而非直接注册为IHostedService），然后注册ParallelHostedServiceExecutor作为唯一的IHostedService：

var builder = Host.CreateDefaultBuilder(args);

// 注册所有Worker为BackgroundService实例
builder.Services.AddSingleton<BackgroundService, Worker1>();
builder.Services.AddSingleton<BackgroundService, Worker2>();
// ... 注册其他所有Worker

// 注册并行执行器，作为Host唯一管理的IHostedService
builder.Services.AddSingleton<IHostedService, ParallelHostedServiceExecutor>();

var host = builder.Build();
await host.RunAsync();

3. 优化Worker内部异步逻辑 #

确保ExitProcessor及内部的ExitSource、Exit、ExitSink方法是真正异步的：

• 避免在这些方法中使用同步阻塞操作（如Thread.Sleep），替换为异步等待（如await Task.Delay）
• 确保所有异步操作都正确传递CancellationToken，以便在强制停机时能及时终止

注意事项 #

• 并行执行时，要确保Worker之间的共享资源访问是线程安全的，避免并发冲突
• 可以通过日志监控每个Worker的停机耗时，定位耗时最长的Worker进行单独优化
• 如果部分Worker的停机逻辑依赖其他Worker的状态，需要调整并行策略（比如分组并行，或者设置依赖顺序）

内容的提问来源于stack exchange，提问作者mathisplewa