构建高性能工作线程 三 工作线程
工作线程
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; }}?