动态定时任务ThreadPoolTaskScheduler

2024-02-27 07:36
文章标签 动态 定时 任务 threadpooltaskscheduler

本文主要是介绍动态定时任务ThreadPoolTaskScheduler，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！ 

在工作中出现了这样一个需求，用户可以制定多个任务，每个任务可以定时分配给多个人。任务的属性包括：任务巡检周期、任务工作日历、巡检人员。
这就需要我们开发一个动态的定时任务功能，而且这个定时任务是可以随时新增、更改、停止的。刚开始接到这个需求的时候我就直接说，我一两天开发不完QwQ，但其实这个功能一点也不难，只是我不知道还有ThreadPoolTaskScheduler这种简便的开发工具罢了，自己菜怨不得需求难。
但是一开始还是走了一些弯路的：

package cn.dxsc.safety.web.config;import cn.dxsc.safety.common.util.ChinaHolidaysUtils;
import cn.dxsc.safety.common.util.StreamUtils;
import cn.dxsc.safety.common.util.StringUtils;
import cn.dxsc.safety.dao.mapper.TaskDistributionMapper;
import cn.dxsc.safety.dao.mapper.TroubleCheckTaskDistributionMapper;
import cn.dxsc.safety.entity.po.TaskDistribution;
import cn.dxsc.safety.entity.po.TroubleCheckTaskDistribution;
import cn.hutool.core.date.DateUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.SchedulingConfigurer;
import org.springframework.scheduling.config.ScheduledTaskRegistrar;
import org.springframework.scheduling.support.CronTrigger;
import org.springframework.stereotype.Component;import javax.annotation.PostConstruct;
import java.io.IOException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
import java.util.stream.Collectors;@Component
public class AutoDistributionTask implements SchedulingConfigurer {//这里有一些是我的业务代码，没有删@Autowiredprivate TroubleCheckTaskDistributionMapper troubleCheckTaskDistributionMapper;@Autowiredprivate TaskDistributionMapper taskDistributionMapper;private List<TroubleCheckTaskDistribution> troubleCheckTaskDistributions;/*** 初始化时调用* 目的：为动态定时任务赋予初始值*/@PostConstructpublic void doConstruct() {this.troubleCheckTaskDistributions = troubleCheckTaskDistributionMapper.selectList(null);}@Overridepublic void configureTasks(ScheduledTaskRegistrar taskRegistrar) {for (TroubleCheckTaskDistribution troubleCheckTaskDistribution : troubleCheckTaskDistributions) {//第一个动态定时任务// 动态使用cron表达式设置循环间隔taskRegistrar.addTriggerTask(() -> System.out.println("Current time： " + DateUtil.now()), triggerContext -> {// 使用CronTrigger触发器，可动态修改cron表达式来操作循环规则CronTrigger cronTrigger = new CronTrigger(troubleCheckTaskDistribution.getCron());
//                //--------此处替换执行操作
//                String workType = troubleCheckTaskDistribution.getWorkType();
//                SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd");
//                boolean publicHolidays = false;
//                try {
//                    publicHolidays = ChinaHolidaysUtils.isPublicHolidays(simpleDateFormat.format(new Date()));
//                } catch (IOException e) {
//                    e.printStackTrace();
//                }
//                //判断工作日类型
//                if(new Date().after(troubleCheckTaskDistribution.getBeginTime()) && !StringUtils.isEmpty(workType))
//                    if ((workType.equals("法定工作日") && publicHolidays)||(workType.equals("非法定工作日") && !publicHolidays)||workType.equals("每天")){
//                        List<TaskDistribution> taskDistributions = taskDistributionMapper.selectList(new LambdaQueryWrapper<TaskDistribution>().eq(TaskDistribution::getTroubleCheckTaskDistributionId, troubleCheckTaskDistribution.getId()))
//                                .stream().filter(StreamUtils.distinctByKey(TaskDistribution::getCheckPeople)).collect(Collectors.toList());
//                        if(taskDistributions.size() != 0){
//                            TaskDistribution taskDistribution = new TaskDistribution();
//                            taskDistribution.setBeginTime(new Date());
//                            taskDistribution.setTroubleCheckTaskDistributionId(troubleCheckTaskDistribution.getId());
//                            taskDistribution.setCheckCompany(taskDistributions.get(0).getCheckCompany());
//                            taskDistributionMapper.insert(taskDistribution);
//                        }
//                    }return cronTrigger.nextExecutionTime(triggerContext);});}}
}

一开始百度到了这样一个方法，可以为动态定时任务赋予初始值，在doConstruct()里获取到了当前数据库里所有的任务的，然后加入到taskRegistrar里面去执行，获取每个任务生成的cron表达式，然后处理业务巴拉巴拉。然后系统一部署后我就不能在新增、修改、删除定时任务了，这怎么能行。
马上，第二种方法：

1、首先创建配置类

package cn.dxsc.safety.common.config;import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ScheduledFuture;/*** @author mrChen* @date 2024/2/23 9:16*/
@Configuration
public class ThreadPoolConfig {public static ConcurrentHashMap<String, ScheduledFuture> cache = new ConcurrentHashMap<String, ScheduledFuture>();@Beanpublic ThreadPoolTaskScheduler threadPoolTaskScheduler() {ThreadPoolTaskScheduler threadPoolTaskScheduler = new ThreadPoolTaskScheduler();threadPoolTaskScheduler.setPoolSize(100);threadPoolTaskScheduler.setThreadNamePrefix("taskExecutor-");threadPoolTaskScheduler.setAwaitTerminationSeconds(10);threadPoolTaskScheduler.setWaitForTasksToCompleteOnShutdown(true);return threadPoolTaskScheduler;}
}

2、然后是一个任务添加、删除的统一处理

package cn.dxsc.safety.web.config;import org.springframework.scheduling.SchedulingException;
import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
import org.springframework.scheduling.config.TriggerTask;
import org.springframework.stereotype.Component;import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ScheduledFuture;/*** @author mrChen* @date 2024/2/22 21:39*/
@Component
public class CronTask {finalThreadPoolTaskScheduler threadPoolTaskScheduler;private Map<String, ScheduledFuture<?>> taskFutures = new ConcurrentHashMap<String, ScheduledFuture<?>>();public CronTask(ThreadPoolTaskScheduler threadPoolTaskScheduler) {this.threadPoolTaskScheduler = threadPoolTaskScheduler;}/*** 添加任务** @param taskId* @param triggerTask*/public void addTriggerTask(String taskId, TriggerTask triggerTask) {if (taskFutures.containsKey(taskId)) {throw new SchedulingException("the taskId[" + taskId + "] was added.");}ScheduledFuture<?> schedule = threadPoolTaskScheduler.schedule(triggerTask.getRunnable(), triggerTask.getTrigger());taskFutures.put(taskId, schedule);}/*** 取消任务** @param taskId*/public void cancelTriggerTask(String taskId) {ScheduledFuture<?> future = taskFutures.get(taskId);if (future != null) {future.cancel(true);}taskFutures.remove(taskId);}
}

3、最后是我的业务代码

@PutMapping("/update")@ApiOperation("根据主键修改")public R update(@RequestBody TroubleCheckTaskDistributionDto dto) {TroubleCheckTaskDistribution h=new TroubleCheckTaskDistribution();BeanUtils.copyProperties(dto, h);String inspCycle = dto.getInspCycle();String inspUnit = dto.getInspUnit();Date beginTime = dto.getBeginTime();int year = beginTime.getYear();int month = beginTime.getMonth() + 1;int day = beginTime.getDay() + 4;int hours = beginTime.getHours();int minutes = beginTime.getMinutes();int seconds = beginTime.getSeconds();//生成cronString cron = "";switch (inspUnit) {case "小时":cron = seconds+" "+minutes+" 0/" + inspCycle + " * * ?";break;case "天":cron = seconds+" "+minutes+" "+hours+" */"+inspCycle+" * ?";//在这个表达式中，“001"表示任务每天的凌晨1点开始执行，"*/3"表示任务每隔三天执行一次，“*"表示任何月份都可以执行，“?”表示不考虑星期几的条件。break;case "月":cron = seconds+" "+minutes+" "+hours+" "+day +" "+"1/"+inspCycle+" ?";break;case "年":cron = seconds+" "+minutes+" "+hours+" "+day+" "+month+" ?";break;}h.setCron(cron);boolean b = iTroubleCheckTaskDistributionService.updateById(h);if (taskHashMap.size() >= 50){return R.fail("所设置的任务已经超标！");}if(this.taskHashMap.containsKey(h.getId())) {cronTask.cancelTriggerTask(String.valueOf(h.getId()));taskHashMap.remove(h.getId());}this.taskHashMap.put(h.getId(), cron);TriggerTask triggerTask = new TriggerTask(new Runnable() {@Overridepublic void run() {System.out.println("Current time： " + DateUtil.now() + "执行任务：" + h.getId());//--------此处替换执行操作String workType = h.getWorkType();SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd");boolean publicHolidays = false;try {publicHolidays = ChinaHolidaysUtils.isPublicHolidays(simpleDateFormat.format(new Date()));} catch (IOException e) {e.printStackTrace();}//判断工作日类型if (new Date().after(h.getBeginTime()) && !StringUtils.isEmpty(workType))if ((workType.equals("法定工作日") && publicHolidays) || (workType.equals("非法定工作日") && !publicHolidays) || workType.equals("每天")) {
//                                List<TaskDistribution> taskDistributions = taskDistributionMapper.selectList(new LambdaQueryWrapper<TaskDistribution>().eq(TaskDistribution::getTroubleCheckTaskDistributionId, h.getId()))
//                                        .stream().filter(StreamUtils.distinctByKey(TaskDistribution::getCheckPeople)).collect(Collectors.toList());List<TaskDistribution> taskDistributions = dto.getTaskDistributions();if (taskDistributions.size() != 0) {for (TaskDistribution taskDistribution : taskDistributions) {taskDistribution.setBeginTime(new Date());taskDistribution.setId(null);taskDistributionMapper.insert(taskDistribution);}}}}},new CronTrigger(this.taskHashMap.get(h.getId())));cronTask.addTriggerTask(String.valueOf(h.getId()), triggerTask);return b ? R.ok() : R.fail();}

一个集坚强与信心于一身的菇凉。

这篇关于动态定时任务ThreadPoolTaskScheduler的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/751658。

相关文章

MySQL 定时新增分区的实现示例

MySQL 定时新增分区的实现示例

《MySQL定时新增分区的实现示例》本文主要介绍了通过存储过程和定时任务实现MySQL分区的自动创建,解决大数据量下手动维护的繁琐问题,具有一定的参考价值,感兴趣的可以了解一下... mysql创建好分区之后，有时候会需要自动创建分区。比如，一些表数据量非常大，有些数据是热点数据，按照日期分区MululbU
阅读更多...
Golang如何对cron进行二次封装实现指定时间执行定时任务

Golang如何对cron进行二次封装实现指定时间执行定时任务

《Golang如何对cron进行二次封装实现指定时间执行定时任务》：本文主要介绍Golang如何对cron进行二次封装实现指定时间执行定时任务问题,具有很好的参考价值,希望对大家有所帮助,如有错误... 目录背景cron库下载代码示例【1】结构体定义【2】定时任务开启【3】使用示例【4】控制台输出总结背景
阅读更多...
在Golang中实现定时任务的几种高效方法

在Golang中实现定时任务的几种高效方法

《在Golang中实现定时任务的几种高效方法》本文将详细介绍在Golang中实现定时任务的几种高效方法,包括time包中的Ticker和Timer、第三方库cron的使用,以及基于channel和go... 目录背景介绍目的和范围预期读者文档结构概述术语表核心概念与联系故事引入核心概念解释核心概念之间的关系
阅读更多...
springboot如何通过http动态操作xxl-job任务

springboot如何通过http动态操作xxl-job任务

《springboot如何通过http动态操作xxl-job任务》：本文主要介绍springboot如何通过http动态操作xxl-job任务的问题,具有很好的参考价值,希望对大家有所帮助,如有错... 目录springboot通过http动态操作xxl-job任务一、maven依赖二、配置文件三、xxl-
阅读更多...
一文详解MySQL如何设置自动备份任务

一文详解MySQL如何设置自动备份任务

《一文详解MySQL如何设置自动备份任务》设置自动备份任务可以确保你的数据库定期备份,防止数据丢失,下面我们就来详细介绍一下如何使用Bash脚本和Cron任务在Linux系统上设置MySQL数据库的自... 目录1. 编写备份脚本1.1 创建并编辑备份脚本1.2 给予脚本执行权限2. 设置 Cron 任务2
阅读更多...
Java调用C#动态库的三种方法详解

Java调用C#动态库的三种方法详解

《Java调用C#动态库的三种方法详解》在这个多语言编程的时代,Java和C#就像两位才华横溢的舞者,各自在不同的舞台上展现着独特的魅力,然而,当它们携手合作时,又会碰撞出怎样绚丽的火花呢？今天,我们... 目录方法1：C++/CLI搭建桥梁——Java ↔ C# 的“翻译官”步骤1：创建C#类库（.NET
阅读更多...
MyBatis编写嵌套子查询的动态SQL实践详解

MyBatis编写嵌套子查询的动态SQL实践详解

《MyBatis编写嵌套子查询的动态SQL实践详解》在Java生态中,MyBatis作为一款优秀的ORM框架,广泛应用于数据库操作,本文将深入探讨如何在MyBatis中编写嵌套子查询的动态SQL,并结... 目录一、Myhttp://www.chinasem.cnBATis动态SQL的核心优势1. 灵活性与可
阅读更多...
Mybatis嵌套子查询动态SQL编写实践

Mybatis嵌套子查询动态SQL编写实践

《Mybatis嵌套子查询动态SQL编写实践》：本文主要介绍Mybatis嵌套子查询动态SQL编写方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录前言一、实体类1、主类2、子类二、Mapper三、XML四、详解总结前言MyBATis的xml文件编写动态SQL
阅读更多...
SpringBoot实现Kafka动态反序列化的完整代码

SpringBoot实现Kafka动态反序列化的完整代码

《SpringBoot实现Kafka动态反序列化的完整代码》在分布式系统中,Kafka作为高吞吐量的消息队列,常常需要处理来自不同主题（Topic）的异构数据,不同的业务场景可能要求对同一消费者组内的... 目录引言一、问题背景1.1 动态反序列化的需求1.2 常见问题二、动态反序列化的核心方案2.1 ht
阅读更多...
golang实现动态路由的项目实践

golang实现动态路由的项目实践

《golang实现动态路由的项目实践》本文主要介绍了golang实现动态路由项目实践,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习... 目录一、动态路由1.结构体（数据库的定义）2.预加载preload3.添加关联的方法一、动态路由1
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2