本文整理了Java中org.redisson.api.RedissonClient.getLock
方法的一些代码示例,展示了RedissonClient.getLock
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。RedissonClient.getLock
方法的具体详情如下:
包路径:org.redisson.api.RedissonClient
类名称:RedissonClient
方法名:getLock
[英]Returns lock instance by name.
Implements a non-fair locking so doesn't guarantees an acquire order by threads.
[中]按名称返回锁实例。
实现非公平锁定,因此不保证线程的获取顺序。
代码示例来源:origin: redisson/redisson
public RedissonPriorityQueue(CommandExecutor commandExecutor, String name, RedissonClient redisson) {
super(commandExecutor, name, redisson);
this.commandExecutor = commandExecutor;
comparatorHolder = redisson.getBucket(getComparatorKeyName(), StringCodec.INSTANCE);
lock = redisson.getLock("redisson_sortedset_lock:{" + getName() + "}");
loadComparator();
}
代码示例来源:origin: redisson/redisson
public RedissonPriorityQueue(Codec codec, CommandExecutor commandExecutor, String name, RedissonClient redisson) {
super(codec, commandExecutor, name, redisson);
this.commandExecutor = commandExecutor;
comparatorHolder = redisson.getBucket(getComparatorKeyName(), StringCodec.INSTANCE);
lock = redisson.getLock("redisson_sortedset_lock:{" + getName() + "}");
loadComparator();
}
代码示例来源:origin: redisson/redisson
public RedissonPriorityQueue(CommandExecutor commandExecutor, String name, RedissonClient redisson) {
super(commandExecutor, name, redisson);
this.commandExecutor = commandExecutor;
comparatorHolder = redisson.getBucket(getComparatorKeyName(), StringCodec.INSTANCE);
lock = redisson.getLock("redisson_sortedset_lock:{" + getName() + "}");
loadComparator();
}
代码示例来源:origin: redisson/redisson
public RedissonPriorityQueue(Codec codec, CommandExecutor commandExecutor, String name, RedissonClient redisson) {
super(codec, commandExecutor, name, redisson);
this.commandExecutor = commandExecutor;
comparatorHolder = redisson.getBucket(getComparatorKeyName(), StringCodec.INSTANCE);
lock = redisson.getLock("redisson_sortedset_lock:{" + getName() + "}");
loadComparator();
}
代码示例来源:origin: redisson/redisson
protected RedissonSortedSet(CommandExecutor commandExecutor, String name, RedissonClient redisson) {
super(commandExecutor, name);
this.commandExecutor = commandExecutor;
this.redisson = redisson;
comparatorHolder = redisson.getBucket(getComparatorKeyName(), StringCodec.INSTANCE);
lock = redisson.getLock("redisson_sortedset_lock:{" + getName() + "}");
list = (RedissonList<V>) redisson.getList(getName());
loadComparator();
}
代码示例来源:origin: redisson/redisson
protected RedissonSortedSet(CommandExecutor commandExecutor, String name, RedissonClient redisson) {
super(commandExecutor, name);
this.commandExecutor = commandExecutor;
this.redisson = redisson;
comparatorHolder = redisson.getBucket(getComparatorKeyName(), StringCodec.INSTANCE);
lock = redisson.getLock("redisson_sortedset_lock:{" + getName() + "}");
list = (RedissonList<V>) redisson.getList(getName());
loadComparator();
}
代码示例来源:origin: io.lsn.spring/utilities
/**
* get named lock
*
* @param name
* @return
*/
public RLock getLock(String name) {
return redissonClient.getLock(name);
}
代码示例来源:origin: io.lsn/spring-core
/**
* get named lock
*
* @param name
* @return
*/
public RLock getLock(String name) {
return redissonClient.getLock(name);
}
代码示例来源:origin: yangwenjie88/delay-queue
/**
* Get lock r lock.
* @param objectName the object name
* @return the r lock
*/
public static RLock getLock(String objectName){
return redissonClient.getLock(objectName);
}
}
代码示例来源:origin: jjj124/SpringLimiter
@Override
public boolean lock(Object key) {
RLock rLock = redisson.getLock(key.toString());
return rLock.tryLock();
}
代码示例来源:origin: jjj124/SpringLimiter
@Override
public void unlock(Object key) {
RLock rLock = redisson.getLock(key.toString());
rLock.unlock();
}
代码示例来源:origin: jiangmin168168/jim-framework
@Override
protected Lock getLock(String key) {
return this.getRedissonClient().getLock(key);
}
代码示例来源:origin: youngMen1/JAVA-
public void unlock(String key) {
redissonClient.getLock(key).unlock();
}
}
代码示例来源:origin: redisson/redisson-examples
public void run() {
RLock lock1 = redisson.getLock("lock");
lock1.lock();
lock1.unlock();
};
};
代码示例来源:origin: techa03/goodsKill
@Override
public void executeWithRedisson(Long seckillId, int executeTime, int userPhone) {
RLock lock = redissonClient.getLock(seckillId + "");
lock.lock();
try {
seckillExecutor.dealSeckill(seckillId, String.valueOf(userPhone), "秒杀场景二(redis分布式锁实现)");
} finally {
lock.unlock();
}
}
代码示例来源:origin: org.redisson/redisson
public RedissonPriorityQueue(CommandExecutor commandExecutor, String name, RedissonClient redisson) {
super(commandExecutor, name, redisson);
this.commandExecutor = commandExecutor;
comparatorHolder = redisson.getBucket(getComparatorKeyName(), StringCodec.INSTANCE);
lock = redisson.getLock("redisson_sortedset_lock:{" + getName() + "}");
loadComparator();
}
代码示例来源:origin: org.redisson/redisson
public RedissonPriorityQueue(Codec codec, CommandExecutor commandExecutor, String name, RedissonClient redisson) {
super(codec, commandExecutor, name, redisson);
this.commandExecutor = commandExecutor;
comparatorHolder = redisson.getBucket(getComparatorKeyName(), StringCodec.INSTANCE);
lock = redisson.getLock("redisson_sortedset_lock:{" + getName() + "}");
loadComparator();
}
代码示例来源:origin: kekingcn/spring-boot-klock-starter
@Override
public boolean acquire() {
try {
rLock = redissonClient.getLock(lockInfo.getName());
return rLock.tryLock(lockInfo.getWaitTime(), lockInfo.getLeaseTime(), TimeUnit.SECONDS);
} catch (InterruptedException e) {
return false;
}
}
代码示例来源:origin: org.redisson/redisson
protected RedissonSortedSet(CommandExecutor commandExecutor, String name, RedissonClient redisson) {
super(commandExecutor, name);
this.commandExecutor = commandExecutor;
this.redisson = redisson;
comparatorHolder = redisson.getBucket(getComparatorKeyName(), StringCodec.INSTANCE);
lock = redisson.getLock("redisson_sortedset_lock:{" + getName() + "}");
list = (RedissonList<V>) redisson.getList(getName());
loadComparator();
}
代码示例来源:origin: dqeasycloud/easy-cloud
/** 根据完整的锁名获取锁 */
private RLock getLock(String lockNameFull, EcLockTypeEnum lockType) {
if (EcLockTypeEnum.isFair(lockType)) {
return redisson.getFairLock(lockNameFull);
} else if (EcLockTypeEnum.isUnfair(lockType)){
return redisson.getLock(lockNameFull);
} else if (EcLockTypeEnum.isRead(lockType)) {
return redisson.getReadWriteLock(lockNameFull).readLock();
} else if (EcLockTypeEnum.isWrite(lockType)) {
return redisson.getReadWriteLock(lockNameFull).writeLock();
}
throw new EcBaseBusinessException(EcLockErrorCodeEnum.LOCK_TYPE_NOT_SUPPORT);
}
内容来源于网络,如有侵权,请联系作者删除!