menuTicketing

Ticketing Python 库

GitHub

代码仓库

bash

示例

基础示例

这是基于 asyncio 的 API。连接到一台服务器后获取 key,并立即释放。

python
broker = TicketBroker.connect("127.0.0.1:5225")
try:
    await broker.wait_ready(5)

    ticket = await broker.acquire("key", wait=5, lease=30)
    await ticket.release()

    print("pass")
finally:
    broker.close()

并发示例(分布式锁)

这是一个验证示例:多个 asyncio 任务通过账户级锁互斥地反复存取款,确认余额最终总能回到初始值。 使用 async with ticket 时,退出该代码块会自动释放。

python
async def transaction(broker: TicketBroker, account: int, delta: int) -> None:
    key = f"account-{account}"

    try:
        ticket = await broker.acquire(key, WAIT, LEASE)
    except Exception as e:
        log.error("account %s acquire failed: %s", account, e)
        return

    async with ticket:
        before = BALANCES[account]
        await asyncio.sleep(0)
        after = before + delta
        BALANCES[account] = after

        action, sign = ("withdraw", "-") if delta < 0 else ("deposit", "+")
        log.info("account %s %s %s$%s -> $%s", account, action, sign, AMOUNT, after)

完整示例请参阅 test_example.pytest_bank.pytest_bench.py