concurrency - ZooKeeperでミューテックスまたはオブジェクトモニターを実装するにはどうすればよいですか？

Question

を使って簡単なクラスを実装したいZooKeeper

    public class ResourceMonitor implements Watcher {
    String name = "/zk_test3";
    ZooKeeper zk;

    public ResourceMonitor() throws IOException {
        zk = new ZooKeeper("localhost:8000", 3000, this);
    }

    public void waitAndGet() {

    }

    public void release() {
        //remove children
    }

    public void process(WatchedEvent event) {
        System.out.println("ResourceMonitor:" + event.toString());
    }
}

私はZooKeeperを初めて使用しますが、ZooKeeperの領収書にそのような例は見つかりませんでした。

Answer 1

githubで分散ロックの実装例を見つけることができます。また、一般的な zk recieptsの実装を持つcurator Zookeeper client を見ることもできます。