更新线程池修改
parent
1fd7f1d348
commit
70bfdfa3d1
|
@ -23,7 +23,9 @@ public class ForceCurrRank extends AbstractRank implements IEventHandler{
|
||||||
|
|
||||||
public ForceCurrRank(int type, String redisKey) {
|
public ForceCurrRank(int type, String redisKey) {
|
||||||
super(type, redisKey);
|
super(type, redisKey);
|
||||||
executor = new ScheduledThreadPoolExecutor(8);
|
if(executor==null){
|
||||||
|
executor = new ScheduledThreadPoolExecutor(8);
|
||||||
|
}
|
||||||
executor.scheduleAtFixedRate(this::run,2,1, TimeUnit.SECONDS);
|
executor.scheduleAtFixedRate(this::run,2,1, TimeUnit.SECONDS);
|
||||||
Poster.getPoster().listenEvent(this, UserMainTeamForceEvent.class);
|
Poster.getPoster().listenEvent(this, UserMainTeamForceEvent.class);
|
||||||
}
|
}
|
||||||
|
@ -31,7 +33,7 @@ public class ForceCurrRank extends AbstractRank implements IEventHandler{
|
||||||
|
|
||||||
private static Queue<UserMainTeamForceEvent> infoQueue = new ArrayDeque<>();
|
private static Queue<UserMainTeamForceEvent> infoQueue = new ArrayDeque<>();
|
||||||
|
|
||||||
private ScheduledThreadPoolExecutor executor;
|
private static ScheduledThreadPoolExecutor executor;
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public int[] getDataByScore(Double score) {
|
public int[] getDataByScore(Double score) {
|
||||||
|
|
Loading…
Reference in New Issue