Merge pull request #130 from LucaLq/main

fix[cache]: fixed a bug where expired data could not be deleted
zfoo-project · Aug 16, 2024 · c8839f1 · c8839f1
2 parents 2c66183 + 4513074
commit c8839f1
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/scheduler/src/main/java/com/zfoo/scheduler/util/LazyCache.java b/scheduler/src/main/java/com/zfoo/scheduler/util/LazyCache.java
@@ -85,6 +85,9 @@ public void put(K key, V value) {
         var cacheValue = new CacheValue<V>();
         cacheValue.value = value;
         cacheValue.expireTime = TimeUtils.now() + expireAfterAccessMillis;
+        if (cacheValue.expireTime < this.minExpireTime) {
+            this.minExpireTime = cacheValue.expireTime;
+        }
         var oldCacheValue = cacheMap.put(key, cacheValue);
         if (oldCacheValue != null) {
             removeListener.accept(List.of(new Pair<>(key, oldCacheValue.value)), RemovalCause.REPLACED);