zoukankan      html  css  js  c++  java
  • Java 定时任务调度(2)--Timer 及 ScheduledThreadPoolExecutor 介绍

    本文主要介绍使用 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);
    }
  • 相关阅读:
    ORA-01207: file is more recent than control file
    ORA-08189
    oracle 修改表空间存储路径
    oracle 日志文件管理
    Oracle ClusterwarePRCT-1011 : Failed to run "oifcfg".&nb
    linux:文件打包与压缩
    linux:查找搜索文件
    Python:lambda表达式(匿名函数)
    网络协议各层概述
    linux:用户及文件权限管理
  • 原文地址:https://www.cnblogs.com/wuyongyin/p/14734382.html
Copyright © 2011-2022 走看看