|
|
|
@ -45,6 +45,7 @@ import java.util.concurrent.locks.Condition;
|
|
|
|
|
* Base class for implementing distributed locks
|
|
|
|
|
*
|
|
|
|
|
* @author Danila Varatyntsev
|
|
|
|
|
* @author Nikita Koksharov
|
|
|
|
|
*/
|
|
|
|
|
public abstract class RedissonBaseLock extends RedissonExpirable implements RLock {
|
|
|
|
|
|
|
|
|
@ -258,11 +259,6 @@ public abstract class RedissonBaseLock extends RedissonExpirable implements RLoc
|
|
|
|
|
return isExistsAsync();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|
public RFuture<Boolean> isExistsAsync() {
|
|
|
|
|
return commandExecutor.writeAsync(getName(), codec, RedisCommands.EXISTS, getName());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|
public boolean isHeldByCurrentThread() {
|
|
|
|
|
return isHeldByThread(Thread.currentThread().getId());
|
|
|
|
|