BackgroundService正常关闭-完成工作并写入数据库

using System;
using System.Threading;
using System.Threading.Tasks;

public class MyBackgroundService : BackgroundService
{
    private readonly CancellationTokenSource _cancellationTokenSource = new CancellationTokenSource();

    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        while (!stoppingToken.IsCancellationRequested)
        {
            try
            {
                // 模拟长时间运行的任务
                await Task.Delay(5000, stoppingToken);
                // 写入数据库
                WriteToDatabase();
            }
            catch (Exception ex)
            {
                // 处理异常
                Console.WriteLine($"Error: {ex.Message}");
            }
        }
    }

    public override void StopAsync(CancellationToken cancellationToken)
    {
        _cancellationTokenSource.Cancel();
        base.StopAsync(cancellationToken);
    }

    private void WriteToDatabase()
    {
        // 写入数据库的逻辑
        Console.WriteLine("Writing to database...");
    }
}