menuTicketing

Библиотека Ticketing для C#

GitHub

Репозиторий

bash
powershell

Пример

Базовый пример

API на основе async/await. Подключение к одному серверу, получение ключа и немедленный возврат.

csharp
var wait = TimeSpan.FromSeconds(5);
var lease = TimeSpan.FromSeconds(30);

await using var broker = TicketBroker.Connect(["127.0.0.1:5225"]);
await broker.WaitReadyAsync(TimeSpan.FromSeconds(5));

var ticket = await broker.AcquireAsync("key", wait, lease);
await ticket.ReleaseAsync();

Console.WriteLine("pass");

Пример конкурентности (распределённая блокировка)

Пример, проверяющий, что несколько задач, взаимно исключая друг друга через блокировку по счёту, при повторяющихся пополнениях/снятиях всегда возвращают баланс к начальному значению.

csharp
private async Task Transaction(int account, long delta)
{
    var key = $"account-{account}";

    Ticket ticket;
    try
    {
        ticket = await _broker.AcquireAsync(key, Wait, Lease);
    }
    catch (Exception e)
    {
        _log.LogError($"account {account} acquire failed: {e.Message}");
        return;
    }

    await using var _ = ticket; // Автоматическое освобождение в фоне при выходе из области видимости

    var before = _balances[account];
    await Task.Yield();
    var after = before + delta;
    _balances[account] = after;

    var (action, sign) = delta < 0 ? ("withdraw", '-') : ("deposit", '+');
    _log.LogInformation($"account {account} {action} {sign}${Amount} -> ${after}");
}

Полный пример смотрите в ExampleTest.cs, ExampleBankTest.cs, BenchTest.cs.