diff --git a/serverlogic/src/main/java/com/ljsd/jieling/logic/rank/rankImpl/ForceCurrRank.java b/serverlogic/src/main/java/com/ljsd/jieling/logic/rank/rankImpl/ForceCurrRank.java index 836252935..196105c8d 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/logic/rank/rankImpl/ForceCurrRank.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/logic/rank/rankImpl/ForceCurrRank.java @@ -23,7 +23,9 @@ public class ForceCurrRank extends AbstractRank implements IEventHandler{ public ForceCurrRank(int type, String redisKey) { super(type, redisKey); - executor = new ScheduledThreadPoolExecutor(8); + if(executor==null){ + executor = new ScheduledThreadPoolExecutor(8); + } executor.scheduleAtFixedRate(this::run,2,1, TimeUnit.SECONDS); Poster.getPoster().listenEvent(this, UserMainTeamForceEvent.class); } @@ -31,7 +33,7 @@ public class ForceCurrRank extends AbstractRank implements IEventHandler{ private static Queue infoQueue = new ArrayDeque<>(); - private ScheduledThreadPoolExecutor executor; + private static ScheduledThreadPoolExecutor executor; @Override public int[] getDataByScore(Double score) {