调度预读任务数量调整,改为调度线程池大小x10,降低事务颗粒度,提升性能及稳定性;

pull/72/head
xuxueli 11 months ago
parent 9c386717ff
commit 09cd4828fe

@ -2577,6 +2577,7 @@ public void execute() {
- 5、【重构】任务调度中心底层组件模块化拆分,移除组件单例以及静态代码逻辑,提升组件可维护性; - 5、【重构】任务调度中心底层组件模块化拆分,移除组件单例以及静态代码逻辑,提升组件可维护性;
- 6、【优化】任务调度中心调度锁逻辑优化,事务SQL下沉至Mapper层统一管理,并增加测试用例,提升代码可读性以及可维护性; - 6、【优化】任务调度中心调度锁逻辑优化,事务SQL下沉至Mapper层统一管理,并增加测试用例,提升代码可读性以及可维护性;
- 7、【优化】调度组件日志完善,提升边界情况下问题定位效率; - 7、【优化】调度组件日志完善,提升边界情况下问题定位效率;
- 8、【修复】调度预读任务数量调整,改为调度线程池大小x10,降低事务颗粒度,提升性能及稳定性;
- 7、【ING】UI框架重构升级,提升交互体验; - 7、【ING】UI框架重构升级,提升交互体验;
- 8、【ING】调整资源加载逻辑,移除不必要的拦截器逻辑,提升页面加载效率; - 8、【ING】调整资源加载逻辑,移除不必要的拦截器逻辑,提升页面加载效率;

@ -51,8 +51,8 @@ public class JobScheduleHelper {
} }
logger.info(">>>>>>>>> init xxl-job admin scheduler success."); logger.info(">>>>>>>>> init xxl-job admin scheduler success.");
// pre-read count: treadpool-size * trigger-qps (each trigger cost 50ms, qps = 1000/50 = 20) // pre-read count: treadpool-size * trigger-qps (each trigger cost 100ms, qps = 1000/100 = 100)
int preReadCount = (XxlJobAdminBootstrap.getInstance().getTriggerPoolFastMax() + XxlJobAdminBootstrap.getInstance().getTriggerPoolSlowMax()) * 20; int preReadCount = (XxlJobAdminBootstrap.getInstance().getTriggerPoolFastMax() + XxlJobAdminBootstrap.getInstance().getTriggerPoolSlowMax()) * 10;
// do schedule // do schedule
while (!scheduleThreadToStop) { while (!scheduleThreadToStop) {

Loading…
Cancel
Save