サーバー1台に接続してキーを取得し、すぐに解放します。
const wait = 5000;
const lease = 30000;
const broker = TicketBroker.connect("127.0.0.1:5225");
try {
await broker.waitReady(5000);
const ticket = await broker.acquire("key", wait, lease);
await ticket.release();
console.log("pass");
} finally {
broker.close();
}複数のトランザクションが口座ごとのロックで相互排他しながら入出金を同時に実行しても、残高が常に開始時の値に 戻るかを検証する例です。
async function transaction(broker: TicketBroker, account: number, delta: number): Promise<void> {
const key = `account-${account}`;
let ticket: Ticket;
try {
ticket = await broker.acquire(key, WAIT_MS, LEASE_MS);
} catch (e) {
console.error(`account ${account} acquire failed: ${e}`);
return;
}
const before = balances[account];
await new Promise((resolve) => setImmediate(resolve));
const after = before + delta;
balances[account] = after;
const [action, sign] = delta < 0 ? ["withdraw", "-"] : ["deposit", "+"];
console.info(`account ${account} ${action} ${sign}$${AMOUNT} -> $${after}`);
ticket.close(); // バックグラウンド自動返却
}全体の例はexample.test.ts, bank.test.ts, bench.test.tsで確認してください。