org.redisson.api.RedissonClient.getLock()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(6.4k)|赞(0)|评价(0)|浏览(504)

本文整理了Java中org.redisson.api.RedissonClient.getLock方法的一些代码示例,展示了RedissonClient.getLock的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。RedissonClient.getLock方法的具体详情如下:
包路径:org.redisson.api.RedissonClient
类名称:RedissonClient
方法名:getLock

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);
}

相关文章

微信公众号

最新文章

更多