整理文档，java 动态增加定时任务示例，直接上代码。

import org.apache.tools.ant.util.DateUtils;
import org.quartz.CronTrigger;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerFactory;
import org.quartz.impl.StdSchedulerFactory;

import java.util.Calendar;
import java.util.Date;


/**
 * @Description: 定时任务管理类
 * Created by zhangxb on 2017/2/10.
 */
public class QuartzManager {
  private static SchedulerFactory gSchedulerFactory = new StdSchedulerFactory();
  private static String JOB_GROUP_NAME = "EXTJWEB_JOBGROUP_NAME";
  private static String TRIGGER_GROUP_NAME = "EXTJWEB_TRIGGERGROUP_NAME";

  /**
   * @Description: 添加一个定时任务，使用默认的任务组名，触发器名，触发器组名
   *
   * @param jobName
   *      任务名
   * @param cls
   *      任务
   * @param time
   *      时间设置，参考quartz说明文档
   *
   * @Title: QuartzManager.java
   */
  @SuppressWarnings("unchecked")
  public static void addJob(String jobName, Class cls, String time,Object params) {
    try {
      Scheduler sched = gSchedulerFactory.getScheduler();
      JobDetail jobDetail = new JobDetail(jobName, JOB_GROUP_NAME, cls);// 任务名，任务组，任务执行类
      jobDetail.getJobDataMap().put("params", params);
      // 触发器
      CronTrigger trigger = new CronTrigger(jobName, TRIGGER_GROUP_NAME);// 触发器名,触发器组
      trigger.setCronExpression(time);// 触发器时间设定
      sched.scheduleJob(jobDetail, trigger);
      // 启动
      if (!sched.isShutdown()) {
        sched.start();
      }
    } catch (Exception e) {
      throw new RuntimeException(e);
    }
  }

  /**
   * @Description: 添加一个定时任务
   *
   * @param jobName
   *      任务名
   * @param jobGroupName
   *      任务组名
   * @param triggerName
   *      触发器名
   * @param triggerGroupName
   *      触发器组名
   * @param jobClass
   *      任务
   * @param time
   *      时间设置，参考quartz说明文档
   *
   */
  @SuppressWarnings("unchecked")
  public static void addJob(String jobName, String jobGroupName,
               String triggerName, String triggerGroupName, Class jobClass,
               String time,Object params) {
    try {
      Scheduler sched = gSchedulerFactory.getScheduler();
      JobDetail jobDetail = new JobDetail(jobName, jobGroupName, jobClass);// 任务名，任务组，任务执行类
      jobDetail.getJobDataMap().put("params",params);
      // 触发器
      CronTrigger trigger = new CronTrigger(triggerName, triggerGroupName);// 触发器名,触发器组
      trigger.setCronExpression(time);// 触发器时间设定
      sched.scheduleJob(jobDetail, trigger);
    } catch (Exception e) {
      throw new RuntimeException(e);
    }
  }

  /**
   * @Description: 修改一个任务的触发时间(使用默认的任务组名，触发器名，触发器组名)
   *
   * @param jobName
   * @param time
   *
   */
  @SuppressWarnings("unchecked")
  public static void modifyJobTime(String jobName, String time) {
    try {
      Scheduler sched = gSchedulerFactory.getScheduler();
      CronTrigger trigger = (CronTrigger) sched.getTrigger(jobName,TRIGGER_GROUP_NAME);
      if (trigger == null) {
        return;
      }
      String oldTime = trigger.getCronExpression();
      if (!oldTime.equalsIgnoreCase(time)) {
        JobDetail jobDetail = sched.getJobDetail(jobName,JOB_GROUP_NAME);
        Class objJobClass = jobDetail.getJobClass();
        removeJob(jobName);
        addJob(jobName, objJobClass, time ,jobDetail.getJobDataMap());
      }
    } catch (Exception e) {
      throw new RuntimeException(e);
    }
  }

  /**
   * @Description: 修改一个任务的触发时间
   *
   */
  public static void modifyJobTime(String triggerName,
                   String triggerGroupName, String time) {
    try {
      Scheduler sched = gSchedulerFactory.getScheduler();
      CronTrigger trigger = (CronTrigger) sched.getTrigger(triggerName,triggerGroupName);
      if (trigger == null) {
        return;
      }
      String oldTime = trigger.getCronExpression();
      if (!oldTime.equalsIgnoreCase(time)) {
        CronTrigger ct = (CronTrigger) trigger;
        // 修改时间
        ct.setCronExpression(time);
        // 重启触发器
        sched.resumeTrigger(triggerName, triggerGroupName);
      }
    } catch (Exception e) {
      throw new RuntimeException(e);
    }
  }

  /**
   * @Description: 移除一个任务(使用默认的任务组名，触发器名，触发器组名)
   *
   * @param jobName
   *
   */
  public static void removeJob(String jobName) {
    try {
      Scheduler sched = gSchedulerFactory.getScheduler();
      sched.pauseTrigger(jobName, TRIGGER_GROUP_NAME);// 停止触发器
      sched.unscheduleJob(jobName, TRIGGER_GROUP_NAME);// 移除触发器
      sched.deleteJob(jobName, JOB_GROUP_NAME);// 删除任务
    } catch (Exception e) {
      throw new RuntimeException(e);
    }
  }

  /**
   * @Description: 移除一个任务
   *
   */
  public static void removeJob(String jobName, String jobGroupName,
                 String triggerName, String triggerGroupName) {
    try {
      Scheduler sched = gSchedulerFactory.getScheduler();
      sched.pauseTrigger(triggerName, triggerGroupName);// 停止触发器
      sched.unscheduleJob(triggerName, triggerGroupName);// 移除触发器
      sched.deleteJob(jobName, jobGroupName);// 删除任务
    } catch (Exception e) {
      throw new RuntimeException(e);
    }
  }

  /**
   * @Description:启动所有定时任务
   */
  public static void startJobs() {
    try {
      Scheduler sched = gSchedulerFactory.getScheduler();
      sched.start();
    } catch (Exception e) {
      throw new RuntimeException(e);
    }
  }

  /**
   * @Description:关闭所有定时任务
   *
   */
  public static void shutdownJobs() {
    try {
      Scheduler sched = gSchedulerFactory.getScheduler();
      if (!sched.isShutdown()) {
        sched.shutdown();
      }
    } catch (Exception e) {
      throw new RuntimeException(e);
    }
  }

  public static String formatTime(Date date){
    //0/1 * * * * ?
    String time = DateUtils.format( date, "s m h d * ?");
    System.out.println(time);
    return time;
  }
}

测试类

import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;

import java.text.SimpleDateFormat;
import java.util.Calendar;
import java.util.Date;

/**
 * @Description: 任务执行类
 * Created by zhangxb on 2017/2/10.
 */
public class QuartzJob implements Job {
  @Override
  public void execute(JobExecutionContext context) throws JobExecutionException {
    Object params =  context.getJobDetail().getJobDataMap().get("params");
    System.out.println(params);
    System.out.println(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date())+ "★★★★★★★★★★★");
    System.out.println("【移除定时】开始...");
    QuartzManager.removeJob((String)params);
    System.out.println("【移除定时】成功");
  }
  public static void main(String[] args) {
    try {
      String job_name = "动态任务调度";
      System.out.println("【系统启动】开始(每1秒输出一次)...");
      Calendar cal = Calendar.getInstance();
      cal.add( Calendar.SECOND,10);
      QuartzManager.addJob(job_name, QuartzJob.class, QuartzManager.formatTime(cal.getTime()),job_name);
      Thread.sleep(11);
      cal.setTime( new Date());
      cal.add( Calendar.SECOND,10);
      QuartzManager.addJob(job_name+1, QuartzJob.class, QuartzManager.formatTime(cal.getTime()),job_name+1);
      Thread.sleep(11);
//      System.out.println("【修改时间】开始(每2秒输出一次)...");
//      QuartzManager.modifyJobTime(job_name, "10/2 * * * * ?");
//      Thread.sleep(6000);
//      System.out.println("【移除定时】开始...");
//      QuartzManager.removeJob(job_name);
//      System.out.println("【移除定时】成功");
//
//      System.out.println("【再次添加定时任务】开始(每10秒输出一次)...");
//      QuartzManager.addJob(job_name, QuartzJob.class, "*/10 * * * * ?");
//      Thread.sleep(60000);
//      System.out.println("【移除定时】开始...");
//      QuartzManager.removeJob(job_name);
//      System.out.println("【移除定时】成功");
    } catch (Exception e) {
      e.printStackTrace();
    }
  }
}

不过最后发现，还是没法做动态延迟。后面用延时mq实现的。

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。

# java  # 动态定时任务  # java实现动态定时任务  # java动态添加定时任务  # Java定时任务的三种实现方法  # Java定时任务的三种实现方式  # Quartz实现JAVA定时任务的动态配置的方法  # java实现多线程之定时器任务  # java定时任务Timer和TimerTask使用详解  # 最流行的java后台框架spring quartz定时任务  # java中 spring 定时任务 实现代码  # Java 实现定时任务的三种方法  # 使用java执行定时任务示例  # Java实现定时任务最简单的3种方法  # 移除  # 文档  # 重启  # 大家多多  # 管理类  # 系统启动  # Title  # time  # cls  # void  # addJob  # SuppressWarnings  # unchecked  # EXTJWEB_JOBGROUP_NAME  # TRIGGER_GROUP_NAME  # String  # JOB_GROUP_NAME  # jobName  # gSchedulerFactory  # EXTJWEB_TRIGGERGROUP_NAME 

相关栏目： 【 网站优化151355 】 【 网络推广146373 】 【 网络技术251813 】 【 AI营销90571 】

相关推荐： Claude怎样写结构化提示词_Claude结构化提示词写法【教程】  Laravel Vite是做什么的_Laravel前端资源打包工具Vite配置与使用  在线制作视频的网站有哪些,电脑如何制作视频短片？  活动邀请函制作网站有哪些,活动邀请函文案？  浅述节点的创建及常见功能的实现  高端企业智能建站程序：SEO优化与响应式模板定制开发  Laravel如何实现用户角色和权限系统_Laravel角色权限管理机制  太平洋网站制作公司,网络用语太平洋是什么意思？  phpredis提高消息队列的实时性方法(推荐)  Laravel怎么进行数据库事务处理_Laravel DB Facade事务操作确保数据一致性  如何快速搭建FTP站点实现文件共享？  Laravel怎么创建控制器Controller_Laravel路由绑定与控制器逻辑编写【指南】  Laravel模型事件有哪些_Laravel Model Event生命周期详解  武汉网站设计制作公司,武汉有哪些比较大的同城网站或论坛，就是里面都是武汉人的？  浅谈javascript alert和confirm的美化  javascript如何操作浏览器历史记录_怎样实现无刷新导航  胶州企业网站制作公司,青岛石头网络科技有限公司怎么样？  如何用AI帮你把自己的生活经历写成一个有趣的故事？  Android滚轮选择时间控件使用详解  简单实现Android文件上传  5种Android数据存储方式汇总  Laravel定时任务怎么设置_Laravel Crontab调度器配置  php8.4header发送头信息失败怎么办_php8.4header函数问题解决【解答】  如何快速生成橙子建站落地页链接？  如何在 Go 中优雅地映射具有动态字段的 JSON 对象到结构体  Windows Hello人脸识别突然无法使用  韩国网站服务器搭建指南：VPS选购、域名解析与DNS配置推荐  Laravel如何正确地在控制器和模型之间分配逻辑_Laravel代码职责分离与架构建议  高端云建站费用究竟需要多少预算？  如何快速搭建二级域名独立网站？  Laravel如何实现全文搜索功能？（Scout和Algolia示例）  手机怎么制作网站教程步骤,手机怎么做自己的网页链接？  Laravel如何记录自定义日志？（Log频道配置）  香港服务器租用费用高吗？如何避免常见误区？  Laravel如何实现多语言支持_Laravel本地化与国际化(i18n)配置教程  EditPlus中的正则表达式实战(5)  如何在云服务器上快速搭建个人网站？  edge浏览器无法安装扩展 edge浏览器插件安装失败【解决方法】  瓜子二手车官方网站在线入口 瓜子二手车网页版官网通道入口  Laravel如何监控和管理失败的队列任务_Laravel失败任务处理与监控  uc浏览器二维码扫描入口_uc浏览器扫码功能使用地址  网页制作模板网站推荐,网页设计海报之类的素材哪里好？  国美网站制作流程,国美电器蒸汽鍋怎么用官方网站？  如何在云主机上快速搭建网站？  Laravel怎么实现一对多关联查询_Laravel Eloquent模型关系定义与预加载【实战】  高性能网站服务器配置指南：安全稳定与高效建站核心方案  Win11怎么查看显卡温度 Win11任务管理器查看GPU温度【技巧】  HTML5空格在Angular项目里怎么处理_Angular中空格的渲染问题【详解】  中国移动官方网站首页入口 中国移动官网网页登录  Laravel如何处理和验证JSON类型的数据库字段