Curator 源码初探（三）非重入锁

电玩女神 2022-11-03 12:00 143阅读 0赞

RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3);
    		CuratorFramework client = CuratorFrameworkFactory.newClient(
    				"127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183",
    				retryPolicy);
    		client.start();
    		
    		InterProcessSemaphoreMutex lock = new InterProcessSemaphoreMutex(
    				client, "/locks/lock_01");
    		lock.acquire();
    		lock.release();

底层基于一个信号量模式来实现的，只不过将semaphore 允许获取锁的客户端数量设置为1

public InterProcessSemaphoreMutex(CuratorFramework client, String path)
        {
            this.semaphore = new InterProcessSemaphoreV2(client, path, 1);
        }

那么其实很简单了对吧，那么是如何保证不可重入的呢？

我们来分析一下

（1）线程1 去尝试获取锁，先经历/semaphores/semaphore\_01/lock node 下创建临时顺序节点去尝试加锁

（2）获取锁成功，然后进入/semaphores/semaphore\_01/leases node下去创建临时顺序节点，然后判断children数量个数是否大于maxLeases（也就是1）这样就完成了信号量的获取，然后释放锁

（3）线程2来尝试获取信号量 /semaphores/semaphore\_01/lock node 下创建临时顺序节点去尝试加锁，然后成功，然后去/semaphores/semaphore\_01/leases node下去创建临时顺序节点，然后判断children数量个数是否大于maxLeases发现，size=2，然后就阻塞，这时候是没有释放lock锁的，同时创建了一个watcher 去监听leases 下的节点变化

（4）不可重入的地方来了，这时候线程1 又来尝试获取锁，但是线程lock是没有释放的，会发生什么？现在就会导致线程1注册一个监听watcher 去监听lock node下的 线程2的临时节点的变化，然后阻塞，这样就完成了不可重入性，同时这也造成了程序的卡死，因为资源一直没法释放了对吧