|
|
@ -54,11 +54,15 @@ public class VersionsStore { |
|
|
|
|
|
|
|
|
private void startCleanupTask() { |
|
|
private void startCleanupTask() { |
|
|
cleaner.scheduleAtFixedRate(() -> { |
|
|
cleaner.scheduleAtFixedRate(() -> { |
|
|
long now = System.currentTimeMillis(); |
|
|
try { |
|
|
for (Map.Entry<EdqsObjectKey, TimedValue> entry : versions.entrySet()) { |
|
|
long now = System.currentTimeMillis(); |
|
|
if (now - entry.getValue().lastUpdated > expirationMillis) { |
|
|
for (Map.Entry<EdqsObjectKey, TimedValue> entry : versions.entrySet()) { |
|
|
versions.remove(entry.getKey(), entry.getValue()); |
|
|
if (now - entry.getValue().lastUpdated > expirationMillis) { |
|
|
|
|
|
versions.remove(entry.getKey(), entry.getValue()); |
|
|
|
|
|
} |
|
|
} |
|
|
} |
|
|
|
|
|
} catch (Exception e) { |
|
|
|
|
|
log.error("Cleanup task failed", e); |
|
|
} |
|
|
} |
|
|
}, expirationMillis, expirationMillis, TimeUnit.MILLISECONDS); |
|
|
}, expirationMillis, expirationMillis, TimeUnit.MILLISECONDS); |
|
|
} |
|
|
} |
|
|
|