MapCacheEvictionTask optimization

63275117 · Nikita · 0bb9115d · 63275117
隐藏空白更改
内联并排

Showing with 8 addition and 2 deletion

redisson/src/main/java/org/redisson/eviction/MapCacheEvictionTask.java ...main/java/org/redisson/eviction/MapCacheEvictionTask.java +8 -2

未找到文件。
--- a/redisson/src/main/java/org/redisson/eviction/MapCacheEvictionTask.java
+++ b/redisson/src/main/java/org/redisson/eviction/MapCacheEvictionTask.java
@@ -54,7 +54,10 @@ public class MapCacheEvictionTask extends EvictionTask {
                    + "if v ~= false then "
                        + "local t, val = struct.unpack('dLc0', v); "
                        + "local msg = struct.pack('Lc0Lc0', string.len(key), key, string.len(val), val); "
-                        + "redis.call('publish', KEYS[4], msg); "
+                        + "local listeners = redis.call('publish', KEYS[4], msg); "
+                        + "if (listeners == 0) then "
+                            + "break;"
+                        + "end; "
                    + "end;"  
                + "end;" 
              + "if #expiredKeys1 > 0 then "
@@ -69,7 +72,10 @@ public class MapCacheEvictionTask extends EvictionTask {
                  + "if v ~= false then "
                      + "local t, val = struct.unpack('dLc0', v); "
                      + "local msg = struct.pack('Lc0Lc0', string.len(key), key, string.len(val), val); "
-                      + "redis.call('publish', KEYS[4], msg); "
+                      + "local listeners = redis.call('publish', KEYS[4], msg); "
+                      + "if (listeners == 0) then "
+                          + "break;"
+                      + "end; "
                  + "end;"  
              + "end;" 
              + "if #expiredKeys2 > 0 then "