个人中心
gpt4 book ai didi

02、Java 任务调度 - Timer 及 ScheduledThreadPoolExecutor 介绍

转载 作者：大佬之路 更新时间：2024-01-15 15:51:07 27 4
gpt4 key购买 nike

本文主要介绍使用 Java 原生的 java.util.Timer 和 java.util.concurrent.ScheduledThreadPoolExecutor 来实现定时任务；本文中所使用到的 Java 版本：jdk1.8.0_181。

1、java.util.Timer 使用

@Test
public void test1() throws InterruptedException {
    Timer timer = new Timer();

    timer.schedule(new TimerTask() {
        @Override
        public void run() {
            logger.info("在一个时间点运行一次");
            throw new RuntimeException();
        }
    }, new Date(System.currentTimeMillis() + 2000));

    timer.schedule(new TimerTask() {
        @Override
        public void run() {
            logger.info("延迟3s运行一次");
        }
    }, 3000);

    timer.schedule(new TimerTask() {
        @Override
        public void run() {
            logger.info("延迟4s运行第一次，然后每隔2s运行一次");
        }
    }, 4000, 2000);

    timer.schedule(new TimerTask() {
        @Override
        public void run() {
            logger.info("在一个时间点运行第一次，然后每隔2s运行一次");
        }
    }, new Date(System.currentTimeMillis() + 1000 * 5), 2000);

    Thread.sleep(1000 * 20);
}

@Test
public void test2() throws InterruptedException {
    Timer timer = new Timer();
    timer.scheduleAtFixedRate(new TimerTask() {
        @Override
        public void run() {
            logger.info("延迟3s运行第一次，然后每隔2s运行一次");
        }
    }, 3000, 2000);

    timer.scheduleAtFixedRate(new TimerTask() {
        @Override
        public void run() {
            logger.info("在一个时间点运行第一次，然后每隔2s运行一次");
        }
    }, new Date(System.currentTimeMillis() + 4000), 2000);

    Thread.sleep(1000 * 20);
}

java.util.Timer 有如下缺点：
1、 java.util.Timer是单线程执行任务，如果多个任务在一个时间点执行，会造成任务不能够在准确的时间点执行；
2、 java.util.Timer执行某个任务过程中如果抛出了异常，那么执行线程将会终止，导致其他的任务也不能再执行；
基于java.util.Timer 的缺点，可使用 java.util.concurrent.ScheduledThreadPoolExecutor 来代替 java.util.Timer，ScheduledThreadPoolExecutor 使用线程池来执行任务，不存在上面的缺点。

2、java.util.concurrent.ScheduledThreadPoolExecutor 使用

@Test
public void test3() throws InterruptedException {
    ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(1);
    executor.schedule(() -> {
        logger.info("延迟2s运行一次");
    }, 2, TimeUnit.SECONDS);

    executor.schedule(() -> {
        logger.info("延迟3s运行一次");
        return null;
    }, 3, TimeUnit.SECONDS);

    executor.scheduleAtFixedRate(() -> {
        logger.info("延迟4s运行第一次，然后每隔2s运行一次");
    }, 4, 2, TimeUnit.SECONDS);

    executor.scheduleWithFixedDelay(() -> {
        logger.info("延迟5s运行第一次，上一次任务运行结束后等2s再运行下一次任务。");
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }, 5, 2, TimeUnit.SECONDS);

    Thread.sleep(1000 * 20);
}

27 4 0
文章推荐： 05、Java 任务调度 - Azkaban 入门实战(安装部署)
文章推荐： 01、Java 任务调度 - cron 表达式介绍
文章推荐： 08、Java 任务调度 - ElasticJob 入门实战（ElasticJob-Lite使用）
文章推荐： 07、Java 任务调度 - XXL-JOB 入门实战
大佬之路
个人简介

我是一名优秀的程序员,十分优秀！

滴滴打车优惠券免费领取
滴滴打车优惠券
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com