ソースを参照

使用公平锁

zhouhao 7 年 前
コミット
6e3702aa37

+ 1 - 1
hsweb-concurrent/hsweb-concurrent-lock/hsweb-concurrent-lock-redis/src/main/java/org/hswebframework/web/concurrent/lock/redis/RedissonLockManager.java

@@ -21,7 +21,7 @@ public class RedissonLockManager extends AbstractLockManager {
 
     @Override
     protected Lock createLock(String lockName) {
-        return redisson.getLock(lockName);
+        return redisson.getFairLock(lockName);
     }
 
     @Override

+ 1 - 3
hsweb-concurrent/hsweb-concurrent-lock/hsweb-concurrent-lock-redis/src/test/java/org/hswebframework/web/concurrent/lock/redis/RedissonLockTest.java

@@ -11,8 +11,6 @@ import java.util.concurrent.locks.ReadWriteLock;
 import java.util.function.Consumer;
 
 /**
- * TODO 完成注释
- *
  * @author zhouhao
  */
 public class RedissonLockTest {
@@ -28,7 +26,7 @@ public class RedissonLockTest {
         }
         Config config = new Config();
 //        config.setUseLinuxNativeEpoll(true);
-        config.useSingleServer().setAddress("127.0.0.1:6379");
+        config.useSingleServer().setAddress("redis://127.0.0.1:6379");
         redisson = (Redisson) Redisson.create(config);
         return lockManager = new RedissonLockManager(redisson);
     }