开源动态可监控线程池DynamicTp介绍

线程池实例定义

如果不再配置文件中进行定义，也可以在代码中直接定义

@Configuration

public class DtpConfig {
/**

* [email protected] DynamicTp} 注解定义普通juc线程池，会享受到该框架监控功能，注解名称优先级高于方法名

*

* @return 线程池实例

*/

@DynamicTp("commonExecutor")

@Bean

public ThreadPoolExecutor commonExecutor() {

return (ThreadPoolExecutor) Executors.newFixedThreadPool(1);

}
/**

* [email protected] ThreadPoolCreator} 快速创建一些简单配置的动态线程池

* tips: 建议直接在配置中心配置就行，[email protected]

*

* @return 线程池实例

*/

@Bean

public DtpExecutor dtpExecutor1() {

return ThreadPoolCreator.createDynamicFast("dtpExecutor1");

}
/**

* [email protected] ThreadPoolBuilder} 设置详细参数创建动态线程池（推荐方式），

* ioIntensive，参考tomcat线程池设计，实现了处理io密集型任务的线程池，具体参数可以看代码注释

*

* tips: 建议直接在配置中心配置就行，[email protected]

* @return 线程池实例

*/

@Bean

public DtpExecutor ioIntensiveExecutor() {

return ThreadPoolBuilder.newBuilder()

.threadPoolName("ioIntensiveExecutor")

.corePoolSize(20)

.maximumPoolSize(50)

.queueCapacity(2048)

.ioIntensive(true)

.buildDynamic();

}
/**

* tips: 建议直接在配置中心配置就行，[email protected]

* @return 线程池实例

*/

@Bean

public ThreadPoolExecutor dtpExecutor2() {

return ThreadPoolBuilder.newBuilder()

.threadPoolName("dtpExecutor2")

.corePoolSize(10)

.maximumPoolSize(15)

.keepAliveTime(50)

.timeUnit(TimeUnit.MILLISECONDS)

.workQueue(QueueTypeEnum.SYNCHRONOUS_QUEUE.getName(), null, false)

.waitForTasksToCompleteOnShutdown(true)

.awaitTerminationSeconds(5)

.buildDynamic();

}

}



代码调用

从DtpRegistry中根据线程池名称获取，或者通过依赖注入方式(推荐，更优雅)

依赖注入方式使用，优先推荐依赖注入方式，不能使用依赖注入的场景可以使用方式2

@Resource

private ThreadPoolExecutor dtpExecutor1;
public void exec() {

dtpExecutor1.execute(() -> System.out.println("test"));

}



通过DtpRegistry注册器获取

public static void main(String[] args) {

DtpExecutor dtpExecutor = DtpRegistry.getDtpExecutor("dtpExecutor1");

dtpExecutor.execute(() -> System.out.println("test"));

}



通知报警

调参通知

运行报警

线程池活跃度告警

活跃度 = activeCount / maximumPoolSize

队列容量告警

容量使用率 = queueSize / queueCapacity

拒绝策略告警

线程池线程数达到配置的最大线程数，且任务队列已满，再提交任务会触发拒绝策略

任务队列超时告警

重写ThreadPoolExecutor的execute()方法和beforeExecute()方法，如果配置了执行超时或排队超时值，则会进行报警

任务执行超时告警

重写ThreadPoolExecutor的afterExecute()方法，根据当前时间和beforeExecute()中设置的startTime的差值即可算出任务的实际执行时间，然后判断如果差值大于配置的runTimeout则累加排队超时任务数量,则会进行告警

监控

支持接入prometheus+grafana做监控，效果如下

总结

DynamicTcp是一个功能实用，上手简单动态线程池组件，很轻量对业务无侵入，目前我们业务系统已经开始介入，读者朋友们赶紧使用起来吧。

开源动态可监控线程池DynamicTp介绍的相关教程结束。