Optimizations

Author: verils

pom.xml

@@ -21,18 +21,19 @@
     <name>dlock</name>
 
     <dependencies>
-        <dependency>
-            <groupId>redis.clients</groupId>
-            <artifactId>jedis</artifactId>
-            <version>${jedis.version}</version>
-        </dependency>
-
         <dependency>
             <groupId>org.slf4j</groupId>
             <artifactId>slf4j-api</artifactId>
             <version>${slf4j.version}</version>
         </dependency>
 
+        <dependency>
+            <groupId>redis.clients</groupId>
+            <artifactId>jedis</artifactId>
+            <version>${jedis.version}</version>
+            <optional>true</optional>
+        </dependency>
+
         <dependency>
             <groupId>org.projectlombok</groupId>
             <artifactId>lombok</artifactId>

src/main/java/com/github/verils/dlock/redis/RedisReentrantLock.java

@@ -17,7 +17,7 @@ public class RedisReentrantLock implements DistributedLock {
 
     private final String key;
     private final int expireInSeconds;
-    private final int waitSeconds;
+    private final int sleepMilliseconds;
 
     private String value;
     private int state;
@@ -33,11 +33,11 @@ public RedisReentrantLock(RedisClient redis, String key, int expireInSeconds) {
         this(redis, key, expireInSeconds, 30);
     }
 
-    public RedisReentrantLock(RedisClient redis, String key, int expireInSeconds, int waitSeconds) {
+    public RedisReentrantLock(RedisClient redis, String key, int expireInSeconds, int sleepMilliseconds) {
         this.redis = redis;
         this.key = key;
         this.expireInSeconds = expireInSeconds;
-        this.waitSeconds = waitSeconds;
+        this.sleepMilliseconds = sleepMilliseconds;
     }
 
     @Override
@@ -122,7 +122,7 @@ private void acquire() throws InterruptedException {
         }
         String lock = newLock();
         while (!redis.tryAcquire(key, lock, expireInSeconds)) {
-            Thread.sleep(waitSeconds);
+            Thread.sleep(sleepMilliseconds);
         }
         value = lock;
         state += 1;

src/main/java/com/github/verils/dlock/redis/client/JedisClient.java

@@ -11,8 +11,17 @@ public class JedisClient implements RedisClient {
     private static final String STATUS_OK = "OK";
 
     private static final String NX = "NX";
+
+    /**
+     * 单位：秒
+     */
     private static final String EX = "EX";
 
+    /**
+     * 单位：毫秒
+     */
+    private static final String PX = "PX";
+
     private final JedisPool jedisPool;
 
     public JedisClient(JedisPool jedisPool) {