diff --git a/src/main/java/run/halo/app/event/post/AbstractVisitEventListener.java b/src/main/java/run/halo/app/event/post/AbstractVisitEventListener.java index 7e4946bf9..5af630d9d 100644 --- a/src/main/java/run/halo/app/event/post/AbstractVisitEventListener.java +++ b/src/main/java/run/halo/app/event/post/AbstractVisitEventListener.java @@ -17,9 +17,9 @@ import java.util.concurrent.*; @Slf4j public abstract class AbstractVisitEventListener { - private final Map> postVisitQueueMap; + private final Map> visitQueueMap; - private final Map postVisitTaskMap; + private final Map visitTaskMap; private final BasePostService basePostService; @@ -36,8 +36,8 @@ public abstract class AbstractVisitEventListener { initCapacity = (int) count; } - postVisitQueueMap = new ConcurrentHashMap<>(initCapacity << 1); - postVisitTaskMap = new ConcurrentHashMap<>(initCapacity << 1); + visitQueueMap = new ConcurrentHashMap<>(initCapacity << 1); + visitTaskMap = new ConcurrentHashMap<>(initCapacity << 1); this.executor = Executors.newCachedThreadPool(); } @@ -57,9 +57,9 @@ public abstract class AbstractVisitEventListener { log.debug("Received a visit event, post id: [{}]", id); // Get post visit queue - BlockingQueue postVisitQueue = postVisitQueueMap.computeIfAbsent(id, this::createEmptyQueue); + BlockingQueue postVisitQueue = visitQueueMap.computeIfAbsent(id, this::createEmptyQueue); - postVisitTaskMap.computeIfAbsent(id, this::createPostVisitTask); + visitTaskMap.computeIfAbsent(id, this::createPostVisitTask); // Put a visit for the post postVisitQueue.put(id); @@ -87,17 +87,17 @@ public abstract class AbstractVisitEventListener { */ private class PostVisitTask implements Runnable { - private final Integer postId; + private final Integer id; - private PostVisitTask(Integer postId) { - this.postId = postId; + private PostVisitTask(Integer id) { + this.id = id; } @Override public void run() { while (!Thread.currentThread().isInterrupted()) { try { - BlockingQueue postVisitQueue = postVisitQueueMap.get(postId); + BlockingQueue postVisitQueue = visitQueueMap.get(id); Integer postId = postVisitQueue.take(); log.debug("Took a new visit for post id: [{}]", postId);