From a278b5930026c44164a73587db36fd29b2ba4f04 Mon Sep 17 00:00:00 2001 From: Peter Lawrey Date: Mon, 15 Jun 2020 12:48:56 +0100 Subject: [PATCH] Added CleaningThreadLocal and CleaningThread to clean thread local resources on exit, https://github.com/OpenHFT/Chronicle-Core/issues/122 --- .../java/net/openhft/chronicle/map/perf/MapStress.java | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) diff --git a/src/test/java/net/openhft/chronicle/map/perf/MapStress.java b/src/test/java/net/openhft/chronicle/map/perf/MapStress.java index 12543389d..7ad0a06a5 100644 --- a/src/test/java/net/openhft/chronicle/map/perf/MapStress.java +++ b/src/test/java/net/openhft/chronicle/map/perf/MapStress.java @@ -7,10 +7,7 @@ import java.io.File; import java.io.IOException; import java.io.Serializable; import java.util.Random; -import java.util.concurrent.ExecutionException; -import java.util.concurrent.ExecutorService; -import java.util.concurrent.Executors; -import java.util.concurrent.Future; +import java.util.concurrent.*; import java.util.concurrent.atomic.AtomicInteger; import java.util.stream.IntStream; @@ -23,7 +20,6 @@ public class MapStress { private ExecutorService executor = Executors.newFixedThreadPool(N_WRITE_THREADS + N_READ_THREADS, new NamedThreadFactory("mapStress")); - private ThreadLocal randomTL = ThreadLocal.withInitial(Random::new); public MapStress() throws IOException { } @@ -104,7 +100,7 @@ public class MapStress { long written = 0; do { long time = System.currentTimeMillis(); - final Random random = randomTL.get(); + final Random random = ThreadLocalRandom.current(); IntStream.range(0, 10).forEach(x -> { final int keyIdx = random.nextInt(N_WRITE_THREADS * 100); Security sec = secs[x%5];