1、通信中间件核心模块线程工作由Thread实现改为Timer实现； 2、完善通信中间件远程升级模块及webRemote模块； 3、优化代码。

liurunyu

2024-11-22 1950b0635a0db2c5286f8330e064879e020a7303

 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/core/CoreConstantManage.java

@@ -1,5 +1,6 @@
package com.dy.common.mw.core;

import java.util.ArrayList;
import java.util.List;

import org.apache.logging.log4j.*;
@@ -10,10 +11,12 @@
   
   private final static CoreConstantManage instance = new CoreConstantManage() ;

   private static Long sleepBigBusy = 100L ;//大忙时（除了恒久任务，还是其他任务），核心线程暂停间隔
   private static Long sleepSmallBusy = 500L ;//小忙时（只有恒久任务，无其他任务），核心线程暂停间隔
	
   private List<CoreConstantTimer> coreConstantTimers ;

   private Long coreInterval = 100L ;//核心线程暂停间隔

   private CoreConstantManage(){
      coreConstantTimers = new ArrayList<>() ;
   }
   
   public static CoreConstantManage getInstance(){
@@ -22,12 +25,10 @@
   
   /**
    * 设置暂停时长
    * @param sleepBigBusy 大忙时（除了恒久任务，还是其他任务），核心线程暂停间隔
    * @param sleepSmallBusy 小忙时（只有恒久任务，无其他任务），核心线程暂停间隔
    * @param coreInterval 核心线程暂停间隔
    */
   public void setSleep(Long sleepBigBusy, Long sleepSmallBusy){
      CoreConstantManage.sleepBigBusy = sleepBigBusy ;
      CoreConstantManage.sleepSmallBusy = sleepSmallBusy ;
   public void setSleep(Long coreInterval){
      this.coreInterval = coreInterval ;
   }

   public void start(){
@@ -35,7 +36,8 @@
      List<CoreTask> constantTasks = CoreUnit.getAllConstantTasks();
      if (constantTasks != null && constantTasks.size() > 0) {
         for (CoreTask task : constantTasks) {
            new CoreConstantThread(sleepBigBusy, sleepSmallBusy, task).start();
            //new CoreConstantThread(sleepBigBusy, sleepSmallBusy, task).start();
            coreConstantTimers.add(new CoreConstantTimer(coreInterval, task).start());
         }
      }
   }