构建高性能工作线程 三 工作线程

工作线程

public abstract class WorkThread implements Runnable, Serializable{
    /** 线程池的参数是否改变 */
    private boolean isPoolSizeAliveTimeModf = false;
    /** JDK 线程池 spring封装 扩展实现的线程池 */
    private MyThreadPoolTaskExecutor taskExecutor;

    /** 核心线程数 */
    private static int corePoolSize;
    /** 最大线程数 */
    private static int maximumPoolSize;
    /** 线程池维护线程所允许的空闲时间 */
    private static int keepAliveTime;

    public WorkThread(TaskExecutor taskExecutor) {
      this.taskExecutor = (MyThreadPoolTaskExecutor) taskExecutor;
    }
    
    public final void run() {
        try {
             // 如果线程池参数有变化，则重置
          if (isPoolSizeAliveTimeModf()) {
                 taskExecutor.setCorePoolSize(corePoolSize);
                 taskExecutor.setMaxPoolSize(maximumPoolSize);
                 taskExecutor.setKeepAliveSeconds(keepAliveTime);
            }
            //抽象函数，供子类实现
            doTask();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    
    //任务工作
    public abstract void doTask() throws Exception;

   //获取缓冲队列QUEUE，用于维护监控
   public BlockingQueue getQueue() {
        return taskExecutor.getThreadPoolExecutor().getQueue();
   }

   //获取队列size，用于维护监控
   public int getQueueSize() {
      if (this.getQueue() instanceof LinkedBlockingQueue) {
         return this.getQueue().size();
      } else {
         return this.getQueue().size();
      }
   }
   //如果线程池中的参数有变化，自动调用update方法
   public void update(Observable observable, Object obj) {
       if (obj instanceof Map) {
           HashMap<String, Integer> poolMap = (HashMap<String, Integer>) obj;
           //打印 线程池  历史大小 和 要更改的大小
       corePoolSize = poolMap.get("corePoolSize");
           maximumPoolSize = poolMap.get("maximumPoolSize");
           keepAliveTime = poolMap.get("keepAliveTime");

           //一定要把值设到线程池中
       taskExecutor.setCorePoolSize(corePoolSize);
           taskExecutor.setMaxPoolSize(maximumPoolSize);
           taskExecutor.setKeepAliveSeconds(keepAliveTime);
       }
   }

   public MyThreadPoolTaskExecutor getTaskExecutor() {
      return taskExecutor;
   }
   public void setMaximumPoolSize(int maximumPoolSize) {
      this.maximumPoolSize = maximumPoolSize;
   }
   public boolean isPoolSizeAliveTimeModf() {
      return isPoolSizeAliveTimeModf;
   }
   public void setKeepAliveTime(int keepAliveTime) {
      this.keepAliveTime = keepAliveTime;
   }

}