资讯详情

Quartz动态设置并发数量

📅 2026/10/21 2:47:51 | 华诺云谱 👁 阅读
Quartz动态设置并发数量
源码仓库Gitee·GitHubquartz存在一个问题当正在进行的任务已经达到了设置的个数后续触发的任务没有线程可用会导致系统宕机Quartz通过StdSchedulerFactory工厂创建调度器initialize方法通过解析quartz.properties配置信息进行加载默认线程个数为10可以通过覆盖信息定义线程个数通过Apollo信息进行线程个数配置Scheduler scheduler (new StdSchedulerFactory()).getScheduler(); //获取Apollo配置信息 Config config ConfigService.getConfig(application); String threadCount config.getProperty(org.quartz.threadPool.threadCount, ); //对quartz.properties配置信息进行覆盖 Properties props new Properties(); InputStream in TaskScheduleServiceImpl.class.getClassLoader().getResourceAsStream(quartz.properties); props.load(in); String threadCountProperties props.get(org.quartz.threadPool.threadCount).toString(); if (.equals(threadCount)) { if (!threadCount.equals(threadCountProperties)) { props.setProperty(org.quartz.threadPool.threadCount, threadCount); //重新创建调度器 StdSchedulerFactory stdSchedulerFactory new StdSchedulerFactory(); stdSchedulerFactory.initialize(props); //关闭原先调度器 scheduler.shutdown(); scheduler stdSchedulerFactory.getScheduler(); in.close(); } }上面代码是在系统初始化中执行的若想实现系统运行中进行动态扩容/缩容调度器线程池大小可以加一个flag标志进行判断通过获取当前系统正在执行的任务个数和系统定义的总数进行对比当达到一定个数或一定比例时再次调用上面代码进行动态扩容/缩容。上面代码存在的问题是当关闭调度器时会杀死原先存在正在进行的任务这是不友好的操作可以添加一个中间件(Redis)将每次触发执行的任务加入Redis中执行完从Redis删除所以每次系统重启都从Redis读取数据对任务重新执行执行完再将其从Redis删除同时为了保证任务的唯一性(集群环境下不管是定时还是立即执行)需要对任务进行加锁操作由于只需要保证同一时刻只能有一个任务在运行保证高可用而不追求强一致性所以选择的是Redis分布式锁Redisson根据先到先得策略使用了Redisson的公平锁。
📝

华诺云谱内容团队

资深建站顾问 · 行业研究员

10年+企业数字化服务经验,专注智能建站、SEO优化与品牌营销,持续输出建站技巧、行业洞察与营销干货,已帮助5000+企业实现数字化增长。

你可能需要的服务

订阅华诺云谱资讯周报

每周一封,精选建站技巧、SEO与营销干货,直达邮箱。已有 8,000+ 企业主订阅,助你少走弯路。

↑