From 1ff3a06263b18daee6b73325c96d052fe59ee70b Mon Sep 17 00:00:00 2001 From: Per Minborg Date: Tue, 1 Sep 2020 16:04:41 +0200 Subject: [PATCH] Cleanup CanonicalRandomAccessFiles --- .../impl/util/CanonicalRandomAccessFiles.java | 23 +++++++++---------- 1 file changed, 11 insertions(+), 12 deletions(-) diff --git a/src/main/java/net/openhft/chronicle/hash/impl/util/CanonicalRandomAccessFiles.java b/src/main/java/net/openhft/chronicle/hash/impl/util/CanonicalRandomAccessFiles.java index 02d2ce273..4d406be2b 100644 --- a/src/main/java/net/openhft/chronicle/hash/impl/util/CanonicalRandomAccessFiles.java +++ b/src/main/java/net/openhft/chronicle/hash/impl/util/CanonicalRandomAccessFiles.java @@ -18,6 +18,7 @@ package net.openhft.chronicle.hash.impl.util; import net.openhft.chronicle.core.CleaningRandomAccessFile; import net.openhft.chronicle.core.Jvm; +import org.jetbrains.annotations.NotNull; import java.io.File; import java.io.FileNotFoundException; @@ -27,14 +28,12 @@ import java.util.concurrent.ConcurrentHashMap; public final class CanonicalRandomAccessFiles { - private static final ConcurrentHashMap canonicalRafs = - new ConcurrentHashMap<>(); + private static final ConcurrentHashMap CANONICAL_RAFS = new ConcurrentHashMap<>(); - private CanonicalRandomAccessFiles() { - } + private CanonicalRandomAccessFiles() {} - public static RandomAccessFile acquire(File file) throws FileNotFoundException { - return canonicalRafs.compute(file, (f, ref) -> { + public static RandomAccessFile acquire(@NotNull final File file) throws FileNotFoundException { + return CANONICAL_RAFS.compute(file, (f, ref) -> { if (ref == null) { try { return new RafReference(new CleaningRandomAccessFile(f, "rw")); @@ -48,8 +47,8 @@ public final class CanonicalRandomAccessFiles { }).raf; } - public static void release(File file) throws IOException { - canonicalRafs.computeIfPresent(file, (f, ref) -> { + public static void release(@NotNull final File file) throws IOException { + CANONICAL_RAFS.computeIfPresent(file, (f, ref) -> { if (--ref.refCount == 0) { try { ref.raf.close(); @@ -63,11 +62,11 @@ public final class CanonicalRandomAccessFiles { }); } - private static class RafReference { - RandomAccessFile raf; - int refCount; + private static final class RafReference { + private final RandomAccessFile raf; + private int refCount; - RafReference(RandomAccessFile raf) { + RafReference(@NotNull final RandomAccessFile raf) { this.raf = raf; refCount = 1; }