十、curator recipes之信号量InterProcessSemaphoreV2

import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.framework.recipes.locks.InterProcessSemaphoreV2;
import org.apache.curator.framework.recipes.locks.Lease;
import org.apache.curator.retry.ExponentialBackoffRetry;

public class InterProcessSemaphoreDemo {
    private static CuratorFramework client = CuratorFrameworkFactory.newClient("localhost:2181", new ExponentialBackoffRetry(3000, 2));
    private static String path = "/semaphore/0001";
    static {
        client.start();
    }

    public static void main(String[] args) throws InterruptedException {
        startThread0();
        startThread1();
        Thread.sleep(50000);
        client.close();
    }

    private static void startThread1() {
        new Thread(() -> {
            InterProcessSemaphoreV2 semaphoreV2 = new InterProcessSemaphoreV2(client, path, 1);
            Lease lease = null;
            try {
                System.out.println("thread0 acquiring");
                lease = semaphoreV2.acquire();
                System.out.println("thread0 acquired and sleeping");
                Thread.sleep(3000);
            } catch (Exception e) {
                e.printStackTrace();
            } finally {
                semaphoreV2.returnLease(lease);
                System.out.println("thread0 return lease");
            }
        }).start();
    }

    private static void startThread0() {
        new Thread(() -> {
            InterProcessSemaphoreV2 semaphoreV2 = new InterProcessSemaphoreV2(client, path, 1);
            Lease lease = null;
            try {
                System.out.println("thread1 acquiring");
                lease = semaphoreV2.acquire();
                System.out.println("thread1 acquired and sleeping");
                Thread.sleep(3000);
            } catch (Exception e) {
                e.printStackTrace();
            } finally {
                semaphoreV2.returnLease(lease);
                System.out.println("thread1 return lease");
            }
        }).start();
    }
}