com.zoi7.component.zookeeper

类 ZkDistributedLock

java.lang.Object

com.zoi7.component.zookeeper.ZkDistributedLock

所有已实现的接口:

java.util.concurrent.locks.Lock, org.apache.zookeeper.Watcher

public class ZkDistributedLock
extends java.lang.Object
implements java.util.concurrent.locks.Lock, org.apache.zookeeper.Watcher

基于Zookeeper实现的分布式锁

作者:

yjy 2018-10-23 11:15

嵌套类概要

从接口继承的嵌套类/接口 org.apache.zookeeper.Watcher

org.apache.zookeeper.Watcher.Event

构造器概要

构造器

构造器和说明
ZkDistributedLock(java.lang.String lockName)

方法概要

限定符和类型	方法和说明
void	lock() 获取锁, 如果当前非空闲, 则等待锁释放 由于 lock(); 方法如果在遇到阻塞情况将会一直等待下去(等待时间为Long.MAX_VALUE毫秒), 这可能会导致意想不到的情况 建议使用 tryLock(time, unit);
void	lockInterruptibly()
java.util.concurrent.locks.Condition	newCondition()
void	process(org.apache.zookeeper.WatchedEvent event) 监听锁释放事件
boolean	tryLock() 尝试获取锁, 直接返回是否成功
boolean	tryLock(long time, java.util.concurrent.TimeUnit unit) 尝试获取锁, 如果当前非空闲, 则等待, 如果在指定时间内还是未获取到锁, 则获取锁失败
void	unlock() 释放当前锁

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

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

构造器详细资料

ZkDistributedLock

public ZkDistributedLock(java.lang.String lockName)
                  throws java.lang.InterruptedException,
                         java.io.IOException,
                         org.apache.zookeeper.KeeperException

抛出:

java.lang.InterruptedException

java.io.IOException

org.apache.zookeeper.KeeperException

方法详细资料

lock

public void lock()

获取锁, 如果当前非空闲, 则等待锁释放 由于 lock(); 方法如果在遇到阻塞情况将会一直等待下去(等待时间为Long.MAX_VALUE毫秒), 这可能会导致意想不到的情况 建议使用 tryLock(time, unit);

指定者:

lock 在接口中 java.util.concurrent.locks.Lock

tryLock

public boolean tryLock(long time,
                       java.util.concurrent.TimeUnit unit)
                throws java.lang.InterruptedException

尝试获取锁, 如果当前非空闲, 则等待, 如果在指定时间内还是未获取到锁, 则获取锁失败

指定者:

tryLock 在接口中 java.util.concurrent.locks.Lock

参数:

time - 时间

unit - 时间单位

返回:

是否获取成功

抛出:

java.lang.InterruptedException - e

tryLock

public boolean tryLock()

尝试获取锁, 直接返回是否成功

指定者:

tryLock 在接口中 java.util.concurrent.locks.Lock

返回:

是否成功获取锁

lockInterruptibly

public void lockInterruptibly()

指定者:

lockInterruptibly 在接口中 java.util.concurrent.locks.Lock

unlock

public void unlock()

释放当前锁

指定者:

unlock 在接口中 java.util.concurrent.locks.Lock

newCondition

public java.util.concurrent.locks.Condition newCondition()

指定者:

newCondition 在接口中 java.util.concurrent.locks.Lock

process

public void process(org.apache.zookeeper.WatchedEvent event)

监听锁释放事件

指定者:

process 在接口中 org.apache.zookeeper.Watcher

参数:

event - 事件