서버 하나에 접속해 키를 획득하고 바로 반납하는 최소 예제입니다. Go는 async/await가 없으므로 블로킹 API에 백그라운드 goroutine을 결합한 형태로 제공됩니다.
wait := 5 * time.Second
lease := 30 * time.Second
broker := Connect("127.0.0.1:5225")
defer broker.Close()
broker.WaitReady(5 * time.Second)
ticket, err := broker.Acquire("key", wait, lease)
if err != nil {
log.Fatalf("acquire: %v", err)
}
if _, err := ticket.Release(); err != nil {
log.Fatalf("release: %v", err)
}
fmt.Println("pass")여러 goroutine이 계좌별 락으로 상호배제하며 입금/출금을 반복해도 잔액이 항상 시작값으로 돌아오는지 검증하는 예제입니다.
transaction := func(account int, delta int64) {
key := fmt.Sprintf("account-%d", account)
ticket, err := broker.Acquire(key, bankWait, bankLease)
if err != nil {
log.Printf("account %d acquire failed: %v", account, err)
return
}
before := balances[account]
runtime.Gosched()
after := before + delta
balances[account] = after
ticket.Close() // 백그라운드 자동 반납
action, sign := "deposit", "+"
if delta < 0 {
action, sign = "withdraw", "-"
}
log.Printf("account %d %s %s$%d -> $%d", account, action, sign, bankAmount, after)
}전체 예제는 example_test.go, bank_example_test.go, bench_test.go에서 확인하세요.