diff --git a/src/main/java/net/openhft/chronicle/map/OldDeletedEntriesCleanupThread.java b/src/main/java/net/openhft/chronicle/map/OldDeletedEntriesCleanupThread.java index 791748c23..3a6253b7d 100644 --- a/src/main/java/net/openhft/chronicle/map/OldDeletedEntriesCleanupThread.java +++ b/src/main/java/net/openhft/chronicle/map/OldDeletedEntriesCleanupThread.java @@ -72,7 +72,7 @@ class OldDeletedEntriesCleanupThread extends Thread private long prevSegment0ScanStart = -1; private long removedCompletely; - + private long startTime = System.currentTimeMillis(); OldDeletedEntriesCleanupThread(ReplicatedChronicleMap map) { super("Cleanup Thread for " + map.toIdentityString()); setDaemon(true); @@ -116,6 +116,9 @@ class OldDeletedEntriesCleanupThread extends Thread @Override public void run() { + if (System.currentTimeMillis() - startTime < 1_000) + return; + while (!shutdown) { int nextSegmentIndex = cleanupSegment(); if (nextSegmentIndex == -1)