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

2021/7/23 11:06:54

编程Tag： 源码互斥节点信号量分布式 Semaphore 01 semaphores

本文主要是介绍ZooKeeper 分布式锁 Curator 源码 04：分布式信号量和互斥锁，对大家解决编程问题具有一定的参考价值，需要的程序猿们随着小编来一起学习吧！

前言

分布式信号量，之前在 Redisson 中也介绍过，Redisson 的信号量是将计数维护在 Redis 中的，那现在来看一下 Curator 是如何基于 ZooKeeper 实现信号量的。

使用 Demo

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);

    }
}

控制台输出数据如下：