Program.cs

using CSharpener;

// ── Wiring ────────────────────────────────────────────────────────────────────
var corePool = new CorePool();
var registry = new OperationRegistry(corePool);
var cts      = new CancellationTokenSource();

var tokenQueue  = new AdmissionQueue<Token> (corePool);
var ticketQueue = new AdmissionQueue<Ticket>(corePool);

var tokenizer     = new Tokenizer    (tokenQueue,  registry);
var ticketCreator = new TicketCreator(ticketQueue, registry);

var background = Task.WhenAll(
    tokenQueue .DrainAsync(cts.Token),
    ticketQueue.DrainAsync(cts.Token),
    corePool   .StartAsync(cts.Token));

// ── Load test ─────────────────────────────────────────────────────────────────
var loadTest = new LoadTest(tokenizer, ticketCreator);
await loadTest.RunAsync(LoadTestConfig.Light);

// ── Statement test ────────────────────────────────────────────────────────────
var statementTest = new StatementTest(tokenizer, ticketCreator);
await statementTest.RunAsync(waves: 10, groupsPerDomain: 25);

cts.Cancel();
try { await background; } catch { }
Console.WriteLine("\nDone.");