github
/
halo
mirror of https://github.com/halo-dev/halo
1
0
Fork 0
Code Issues Releases Wiki Activity

Change some variable names

pull/146/head
johnniang 2019-04-24 23:35:08 +08:00
parent 4695868fa7
commit 8b80ed69b1
1 changed files with 10 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
src/main/java/run/halo/app/event/post/AbstractVisitEventListener.java
View File

@ -17,9 +17,9 @@ import java.util.concurrent.*;
@Slf4j
public abstract class AbstractVisitEventListener {
private final Map<Integer, BlockingQueue<Integer>> postVisitQueueMap;
private final Map<Integer, BlockingQueue<Integer>> visitQueueMap;
private final Map<Integer, PostVisitTask> postVisitTaskMap;
private final Map<Integer, PostVisitTask> 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<Integer> postVisitQueue = postVisitQueueMap.computeIfAbsent(id, this::createEmptyQueue);
BlockingQueue<Integer> 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<Integer> postVisitQueue = postVisitQueueMap.get(postId);
BlockingQueue<Integer> postVisitQueue = visitQueueMap.get(id);
Integer postId = postVisitQueue.take();
log.debug("Took a new visit for post id: [{}]", postId);