net.wicp.tams.commons.zookeeper

类 ZKLockManager

java.lang.Object

net.wicp.tams.commons.zookeeper.ZKLockManager

public class ZKLockManager
extends Object

构造器概要

构造器

构造器和说明
ZKLockManager(String dir)
ZKLockManager(String dir, Host host)
ZKLockManager(String dir, Host host, LockListener lockListener)

方法概要

方法

限定符和类型	方法和说明
String	getCurPath() 得到当前锁的路径
String[]	lock(org.apache.zookeeper.Watcher watcher) 加分布式锁。
Result	unlock() 解除当前拥有的锁
Result	unlock(String path) 解除指定的锁

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

ZKLockManager

public ZKLockManager(String dir)

ZKLockManager

public ZKLockManager(String dir,
             Host host)

ZKLockManager

public ZKLockManager(String dir,
             Host host,
             LockListener lockListener)

方法详细资料

lock

public final String[] lock(org.apache.zookeeper.Watcher watcher)
                    throws org.apache.zookeeper.KeeperException,
                           InterruptedException

加分布式锁。

参数:

watcher - 需要监听事件

返回:

数组，[0]锁的前一个路径 [1]锁的当前路径

抛出:

org.apache.zookeeper.KeeperException

InterruptedException

getCurPath

public final String getCurPath()

得到当前锁的路径

返回:

unlock

public final Result unlock(String path)

解除指定的锁

参数:

path -

返回:

unlock

public final Result unlock()

解除当前拥有的锁

返回: