menuTicketing

Ticketing C/C++ 库

GitHub

尚未在 vcpkg 官方仓库中注册 — 注册要求较为严格,目前仍在准备中。请先克隆上方的 Github 仓库并自行构建使用。

代码仓库

示例

基础示例

这是阻塞式 C API。连接到一台服务器后获取 key,并立即释放。

c
#include "ticketing/ticketing.h"

const char* addrs[1] = {"127.0.0.1:5225"};
ticketing_broker* broker = ticketing_connect(addrs, 1);
ticketing_wait_ready(broker, 2000);

ticketing_ticket* ticket = NULL;
ticketing_result r = ticketing_acquire(broker, "key", 5, 30, &ticket);

bool held = false;
ticketing_release(ticket, &held);
ticketing_ticket_close(ticket);

printf("pass\n");
ticketing_broker_close(broker);

并发示例(分布式锁)

这是一个验证示例:多个 pthread 通过账户级锁互斥地反复存取款,确认余额最终总能回到初始值。

c
static void* transaction(void* arg) {
    op_t* op = (op_t*)arg;
    char key[32];
    snprintf(key, sizeof(key), "account-%d", op->account);

    ticketing_ticket* ticket = NULL;
    ticketing_result r = ticketing_acquire(g_broker, key, WAIT, LEASE, &ticket);
    if (r != TICKETING_OK) {
        fprintf(stderr, "account %d acquire failed: %s\n", op->account, ticketing_strerror(r));
        return NULL;
    }

    int64_t before = balances[op->account];
    sched_yield(); // 仅在持有锁期间的临界区是安全的
    int64_t after = before + op->delta;
    balances[op->account] = after;

    ticketing_ticket_close(ticket); // 后台自动释放

    const char* action = op->delta < 0 ? "withdraw" : "deposit";
    fprintf(stderr, "account %d %s $%" PRId64 " -> $%" PRId64 "\n", op->account, action, op->delta, after);
    return NULL;
}

完整示例请参阅 example_test.cbank_example_test.cbench_test.c