org.apache.shardingsphere.mode.manager.cluster.coordinator.lock.service

类 LockRegistryService

java.lang.Object

org.apache.shardingsphere.mode.manager.cluster.coordinator.lock.service.LockRegistryService

public final class LockRegistryService
extends Object

Lock registry service.

构造器概要

构造器

构造器和说明
LockRegistryService(ClusterPersistRepository repository)

方法概要

限定符和类型	方法和说明
void	ackLock(String lockName) Ack lock.
void	ackUnlock(String lockName) Ack unlock.
boolean	checkLockAck(String lockName, long timeoutMilliseconds) Check lock ack.
void	deleteLockAck(String lockName) Delete lock ack.
void	releaseLock(String lockName) Release lock.
boolean	tryLock(String lockName, long timeoutMilliseconds) Try to get lock.

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

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

构造器详细资料

LockRegistryService

public LockRegistryService(ClusterPersistRepository repository)

方法详细资料

tryLock

public boolean tryLock(String lockName,
                       long timeoutMilliseconds)

Try to get lock.

参数:

lockName - lock name

timeoutMilliseconds - the maximum time in milliseconds to acquire lock

返回:

true if get the lock, false if not

releaseLock

public void releaseLock(String lockName)

Release lock.

参数:

lockName - lock name

ackLock

public void ackLock(String lockName)

Ack lock.

参数:

lockName - lock name

ackUnlock

public void ackUnlock(String lockName)

Ack unlock.

参数:

lockName - lock name

deleteLockAck

public void deleteLockAck(String lockName)

Delete lock ack.

参数:

lockName - lock name

checkLockAck

public boolean checkLockAck(String lockName,
                            long timeoutMilliseconds)

Check lock ack.

参数:

lockName - lock name

timeoutMilliseconds - the maximum time in milliseconds to ack

返回:

true if all instances ack lock, false if not