‫استفاده از قفل‌های توزیع‌شده برای جلوگیری از اجرای مجدد وظایف پشت‌صحنه

dotnet add package Medallion.RedisDistributedLock

builder.Services.AddSingleton<IDistributedLockProvider>(sp =>
{
    return new RedisDistributedLockProvider("localhost:6379");
});

internal class RedisDistributedLockProvider(string _connectionString) : IDistributedLockProvider
{
    public IDistributedLock CreateLock(string name)
    {
        var connection = ConnectionMultiplexer.Connect(_connectionString);
        return new RedisDistributedLock(name, connection.GetDatabase());
    }
}

private readonly IDistributedLockProvider _lockProvider;

public ScheduledBackgroundJob(IServiceScopeFactory scopeFactory, IDistributedLockProvider lockProvider)
{
    _scopeFactory = scopeFactory;
    _lockProvider = lockProvider;
}

protected override async Task ExecuteAsync(CancellationToken stoppingToken)
{
    var @lock = _lockProvider.CreateLock("ScheduledBackgroundJob");
    using var timer = new PeriodicTimer(TimeSpan.FromMinutes(5));

    do
    {
        await using var handle = await @lock.TryAcquireAsync(TimeSpan.FromSeconds(30), stoppingToken);
        if (handle is not null)
        {
            await DoWorkAsync(stoppingToken);
        }
    }
    while (await timer.WaitForNextTickAsync(stoppingToken)
            && !stoppingToken.IsCancellationRequested);
}

builder.Services.AddHostedService<ScheduledBackgroundJob>();
builder.Services.AddDbContext<MyDbContext>();