From 440b2c4ef8f49b2248416c3883231d05058dbaf2 Mon Sep 17 00:00:00 2001 From: Rob Austin Date: Mon, 13 Apr 2020 15:33:34 +0100 Subject: [PATCH] delayed cleaner --- .../chronicle/map/OldDeletedEntriesCleanupThread.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) 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)