整理文档，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 】

相关推荐： 如何快速搭建高效香港服务器网站？  Laravel如何使用查询构建器？（Query Builder高级用法）  iOS验证手机号的正则表达式  如何注册花生壳免费域名并搭建个人网站？  Python进程池调度策略_任务分发说明【指导】  Laravel如何自定义分页视图？（Pagination示例）  音乐网站服务器如何优化API响应速度？  佐糖AI抠图怎样调整抠图精度_佐糖AI精度调整与放大细化操作【攻略】  WordPress 子目录安装中正确处理脚本路径的完整指南  学生网站制作软件,一个12岁的学生写小说，应该去什么样的网站？  Laravel Debugbar怎么安装_Laravel调试工具栏配置指南  利用JavaScript实现拖拽改变元素大小  js实现获取鼠标当前的位置  Laravel广播系统如何实现实时通信_Laravel Reverb与WebSockets实战教程  Laravel如何使用API Resources格式化JSON响应_Laravel数据资源封装与格式化输出  laravel怎么实现图片的压缩和裁剪_laravel图片压缩与裁剪方法  Laravel如何使用Scope本地作用域_Laravel模型常用查询逻辑封装技巧【手册】  Laravel如何发送系统通知？（Notification渠道示例）  php 三元运算符实例详细介绍  Laravel如何连接多个数据库_Laravel多数据库连接配置与切换教程  如何在阿里云服务器自主搭建网站？  如何解决hover在ie6中的兼容性问题  如何在IIS中新建站点并解决端口绑定冲突？  Laravel怎么定时执行任务_Laravel任务调度器Schedule配置与Cron设置【教程】  如何在IIS7中新建站点？详细步骤解析  详解一款开源免费的.NET文档操作组件DocX（.NET组件介绍之一）  高性价比服务器租赁——企业级配置与24小时运维服务  php8.4header发送头信息失败怎么办_php8.4header函数问题解决【解答】  如何确保FTP站点访问权限与数据传输安全？  lovemo网页版地址 lovemo官网手机登录  Laravel中DTO是什么概念_在Laravel项目中使用数据传输对象(DTO)  如何在宝塔面板创建新站点？  Laravel如何清理系统缓存命令_Laravel清除路由配置及视图缓存的方法【总结】  Laravel怎么实现支付功能_Laravel集成支付宝微信支付  JS去除重复并统计数量的实现方法  原生JS实现图片轮播切换效果  如何打造高效商业网站？建站目的决定转化率  DeepSeek是免费使用的吗 DeepSeek收费模式与Pro版本功能详解  微信小程序 require机制详解及实例代码  如何快速上传建站程序避免常见错误？  如何在Ubuntu系统下快速搭建WordPress个人网站？  Linux虚拟化技术教程_KVMQEMU虚拟机安装与调优  如何做网站制作流程,*游戏网站怎么搭建？  如何制作新型网站程序文件,新型止水鱼鳞网要拆除吗？  购物网站制作费用多少,开办网上购物网站，需要办理哪些手续？  为什么php本地部署后css不生效_静态资源加载失败修复技巧【技巧】  HTML5段落标签p和br怎么选_文本排版常用标签对比【解答】  打开php文件提示内存不足_怎么调整php内存限制【解决方案】  Laravel如何设置定时任务（Cron Job）_Laravel调度器与任务计划配置  微信小程序 scroll-view组件实现列表页实例代码