menuTicketing

Ticketing Java / Kotlin 库

GitHub

这个库在同一个 JVM 中同时包含了 Java 与 Kotlin 两种 API。TicketBroker 是基于 Kotlin 协程的 API,BlockingTicketBroker 则是无需协程即可使用的 Java 友好型阻塞式外观 (基于 java.time.Duration)。它们内部包装的是同一个 broker。

代码仓库

Java, Kotlinhome_and_garden
xml
kts

示例

Kotlin(协程)

kotlin
val broker = TicketBroker.connect("127.0.0.1:5225")
broker.waitReady(5.seconds)

val ticket = broker.acquire("key", 5.seconds, 30.seconds)
ticket.release()

broker.close()

并发示例(通过账户级锁互斥地存取款):

kotlin
suspend fun transaction(broker: TicketBroker, account: Int, delta: Long) {
    val key = "account-$account"
    val ticket = try {
        broker.acquire(key, wait, lease)
    } catch (e: Exception) {
        log.error("account {} acquire failed: {}", account, e.message)
        return
    }
    try {
        val before = balances[account]
        yield()
        balances[account] = before + delta
    } finally {
        ticket.close() // 后台自动释放
    }
    val (action, sign) = if (delta < 0) "withdraw" to '-' else "deposit" to '+'
    log.info("account $account $action $sign\$$AMOUNT -> \$${balances[account]}")
}

Java(阻塞式)

java
try (BlockingTicketBroker broker = BlockingTicketBroker.connect(List.of("127.0.0.1:5225"))) {
    broker.waitReady(Duration.ofSeconds(5));

    BlockingTicket ticket = broker.acquire("key", Duration.ofSeconds(5), Duration.ofSeconds(30));
    ticket.release();

    System.out.println("pass");
}

并发示例(账户级锁,使用 ExecutorService 在多线程中同时执行):

java
void transaction(BlockingTicketBroker broker, int account, long delta) {
    String key = "account-" + account;
    try (BlockingTicket ticket = broker.acquire(key, WAIT, LEASE)) {
        long before = balances[account];
        Thread.yield();
        balances[account] = before + delta;
    }
    String action = delta < 0 ? "withdraw" : "deposit";
    char sign = delta < 0 ? '-' : '+';
    log.info("account {} {} {}${} -> ${}", account, action, sign, AMOUNT, balances[account]);
}

完整示例请参阅 ExampleSimpleTest.kt / ExampleBankTest.kt(Kotlin), ExampleSimpleJavaTest.java / ExampleBankJavaTest.java(Java)。