Don't exit OldDeletedEntriesCleanupThread until a startup delay.

Closes #310
OpenHFT · Jun 18, 2024 · cfc635a · cfc635a
1 parent 7781611
commit cfc635a
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/src/main/java/net/openhft/chronicle/map/OldDeletedEntriesCleanupThread.java b/src/main/java/net/openhft/chronicle/map/OldDeletedEntriesCleanupThread.java
@@ -114,8 +114,9 @@ private static int[] inversePermutation(int[] permutation) {
  public void run() {
  throwExceptionIfClosed();
 
- if (System.currentTimeMillis() - startTime < 1_000)
- return;
+ long runningTime = System.currentTimeMillis() - startTime;
+ if (runningTime < 1_000)
+ sleepMillis(1_000 - runningTime);
 
  while (!shutdown) {
  int nextSegmentIndex;

diff --git a/src/test/java/net/openhft/chronicle/map/MemoryLeaksTest.java b/src/test/java/net/openhft/chronicle/map/MemoryLeaksTest.java
@@ -69,6 +69,7 @@ public MemoryLeaksTest(String testType, boolean replicated, boolean persisted, b
  builder = ChronicleMap
  .of(IntValue.class, String.class).constantKeySizeBySample(Values.newHeapInstance(IntValue.class))
  .valueReaderAndDataAccess(new CountedStringReader(this), new StringUtf8DataAccess());
+ builder.cleanupRemovedEntries(false);
  if (replicated)
  builder.replication((byte) 1);
  builder.entries(1).averageValueSize(10);