|
...
|
...
|
@@ -19,7 +19,7 @@ public class DownGradeService { |
|
|
|
|
|
|
|
private static final Logger logger = LoggerFactory.getLogger("DOWNGRADE");
|
|
|
|
|
|
|
|
private static final ScheduledExecutorService scheduledExecutorService = Executors.newSingleThreadScheduledExecutor();
|
|
|
|
//private static final ScheduledExecutorService scheduledExecutorService = Executors.newSingleThreadScheduledExecutor();
|
|
|
|
|
|
|
|
@Autowired
|
|
|
|
private DownGradeCacheService downGradeCacheService;
|
|
...
|
...
|
@@ -35,7 +35,7 @@ public class DownGradeService { |
|
|
|
// 降级方案：1分钟超时100次
|
|
|
|
downgrade = new AutoDownGradeByOverTime(1, TimeUnit.MINUTES, 100);
|
|
|
|
// 执行定时检查状态的机制
|
|
|
|
scheduledExecutorService.scheduleAtFixedRate(new AutoChangeDownGradeLevel(), 1, 1, TimeUnit.MINUTES);
|
|
|
|
//scheduledExecutorService.scheduleAtFixedRate(new AutoChangeDownGradeLevel(), 1, 1, TimeUnit.MINUTES);
|
|
|
|
//判断默认的降级状态
|
|
|
|
if(this.directDownGrade()){
|
|
|
|
downGradeLevel = DownGradeStateMachine.getDirectDownGradeLevel();
|
...
|
...
|
|
