接入步骤

yanhom接入步骤dynamictp大约 2 分钟

接入步骤

引入相应配置中心的依赖 maven 依赖
配置中心配置线程池实例配置文件
启动类加 @EnableDynamicTp 注解
使用 @Resource or @Autowired or 构造函数进行依赖注入，或通过 DtpRegistry.getExecutor("name") 获取
通过以上 4 步就可以接入使用了，是不是感觉超级简单呀，注意事项需查看

日志输出

启动日志输出

服务启动看到有如下日志输出说明接入成功

|  __ \                            (_) |__   __|   
| |  | |_   _ _ __   __ _ _ __ ___  _  ___| |_ __  
| |  | | | | | '_ \ / _` | '_ ` _ \| |/ __| | '_ \ 
| |__| | |_| | | | | (_| | | | | | | | (__| | |_) |
|_____/ \__, |_| |_|\__,_|_| |_| |_|_|\___|_| .__/ 
       __/ |                              | |    
      |___/                               |_|   
:: Dynamic Thread Pool :: 
:: 1.2.0 :: 
:: https://dynamictp.cn ::
:: https://github.com/dromara/dynamic-tp ::
:: https://gitee.com/dromara/dynamic-tp ::

DynamicTp register executor: TpMainFields(threadPoolName=dtpExecutor1, corePoolSize=2, maxPoolSize=10, keepAliveTime=50, queueType=TaskQueue, queueCapacity=200, rejectType=CallerRunsPolicy, allowCoreThreadTimeOut=false), source: beanPostProcessor

DtpRegistry has been initialized, remote executors: [dtpExecutor1], local executors: [ioIntensiveExecutor, commonExecutor, dtpExecutor2]

注意事项

注意

若项目中用到了其他 agent 工具，比如 skywalking、ttl 等，他们也会对线程做拦截增强，跟满血 dtp 会有冲突，可能会造成 OOM，需要引入该依赖 agent 模式下依赖
普通 JUC 线程池或者 Spring 线程池想要被框架管理，可以 @Bean 定义时加 @DynamicTp 注解，同时配置文件中添加配置项 autoCreate: false
动态线程池实例服务启动时会根据配置中心的配置动态注册到 Spring 容器中，建议不要用 @Bean 编程式重复声明同一线程池实例，直接配置在配置中心就行
阻塞队列只有 VariableLinkedBlockingQueue 及其子类可以修改 capacity，该类型功能和 LinkedBlockingQueue 相似，只是 capacity 不是 final 类型，可以修改，VariableLinkedBlockingQueue 参考 RabbitMq 的实现