ZooKeeper 分布式锁 Curator 源码 04：分布式信号量和互斥锁

public class CuratorDemo {
    public static void main(String[] args) throws Exception {
        String connectString = "127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183";
        RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3);
        CuratorFramework client = CuratorFrameworkFactory                .builder()                .connectString(connectString)                .retryPolicy(retryPolicy)                .build();        client.start();
        InterProcessSemaphoreV2 semaphore = new InterProcessSemaphoreV2(client, "/semaphores/semaphore_01", 3);
        for (int i = 0; i < 10; i++) {            new Thread(() -> {                try {                    System.out.println(Thread.currentThread() + " 线程 start - " + LocalTime.now());                    Lease lease = semaphore.acquire();                    System.out.println(Thread.currentThread() + " 线程 execute - " + LocalTime.now());                    Thread.sleep(3000);                    System.out.println(Thread.currentThread() + " 线程 over -" + LocalTime.now());                    semaphore.returnLease(lease);                } catch (Exception e) {
                }
            }).start();        }
        Thread.sleep(1000000);
    }}