|
@@ -62,6 +62,7 @@ public class RedisConcurrentService implements ConcurrentService, RedisConstant
|
|
@Override
|
|
@Override
|
|
public Semaphore getSemaphore(@NotNull String name) {
|
|
public Semaphore getSemaphore(@NotNull String name) {
|
|
RSemaphore semaphore = redissonClient.getSemaphore(name);
|
|
RSemaphore semaphore = redissonClient.getSemaphore(name);
|
|
|
|
+ semaphore.trySetPermits(1);
|
|
return new Semaphore() {
|
|
return new Semaphore() {
|
|
|
|
|
|
@Override
|
|
@Override
|