定时任务-ScheduledExecutorService

创建定时任务线程池的方式

ScheduledExecutorService executorService = Executors.newScheduledThreadPool(4);// 不推荐
// 或

ScheduledExecutorService executorService = new ScheduledThreadPoolExecutor(4);// 推荐

创建定时任务的方法

public interface ScheduledExecutorService extends ExecutorService {

    /**
     * 延迟delay（时间单位由unit指定）后执行任务
     *
     * @param command   任务
     * @param delay     延迟时间
     * @param unit      时间单位
     * @return          执行结果
     */
    public ScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit);

    /**
     * 延迟delay（时间单位由unit指定）时间后执行任务
     * 任务执行完毕后，返回执行结果
     *
     * @param callable  任务
     * @param delay     延迟时间
     * @param unit      时间单位
     * @return          执行结果
     */
    public <V> ScheduledFuture<V> schedule(Callable<V> callable, long delay, TimeUnit unit);

    /**
     * 延迟delay时间后执行第一次任务，之后每过period毫秒执行一次。
     * 假设:
     *      执行一次任务需要消耗的时间为 exeTime
     *      执行此次任务的开始时间是 nowTime
     *      执行下一次任务的实际时间是 actuallyTime
     * 如果 exeTime >= period ，那么，actuallyTime >= nowTime + exeTime;
     * 如果 exeTime < period ， 那么，actuallyTime >= nowTime + period;
     *
     * @param command       任务
     * @param initialDelay  执行首次任务之前的延时时间
     * @param period        周期性执行任务，相邻两次的时间间隔
     * @param unit          时间单位
     * @return              执行结果
     */
    public ScheduledFuture<?> scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit);

    /**
     * 延迟initialDelay时间后执行首次任务，之后的任务执行，全部在上次任务执行完毕之后，再延迟delay时间执行。
     *
     * 假设:
     *      执行一次任务需要消耗的时间为 exeTime
     *      执行此次任务的开始时间是 nowTime
     *      执行下一次任务的实际时间是 actuallyTime
     * 如果 exeTime >= period ，那么，actuallyTime >= nowTime + exeTime + delay;
     * 如果 exeTime < period ， 那么，actuallyTime >= nowTime + exeTime + period;
     *
     * @param command　　　　任务
     * @param initialDelay　执行首次任务之前的延迟时间
     * @param delay　　　　　每次任务执行完成后，执行下次任务之前的延迟时间
     * @param unit　　　　　　时间单位
     * @return
     */
    public ScheduledFuture<?> scheduleWithFixedDelay(Runnable command, long initialDelay, long delay, TimeUnit unit);

}

创建定时任务的示例

示例一：延迟执行

package com.java.scheduled.task.pool;

import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public class ScheduledTaskDemo01 {

    public static void main(String[] args) {
        ScheduledExecutorService executorService = new ScheduledThreadPoolExecutor(4);
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        Date date = new Date();
        System.out.println("安排执行任务的时间："+sdf.format(date));
        long c1 = date.getTime();
        Runnable runnable = () -> {
            Date nowDate = new Date();
            System.out.println("****计划任务（1）：【延迟2秒执行】");
            System.out.println("实际执行任务的时间："+sdf.format(nowDate));
            System.out.println("延迟时间："+(nowDate.getTime() - c1)+"ms");
        };
        executorService.schedule(runnable, 2, TimeUnit.SECONDS);
    }
    
}

执行结果如下：

安排执行任务的时间：2019-05-28 12:10:46
****计划任务（1）：【延迟2秒执行】
实际执行任务的时间：2019-05-28 12:10:48
延迟时间：2087ms

示例二：延迟执行，返回结果

package com.java.scheduled.task.pool;

import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.concurrent.*;

public class ScheduledTaskDemo02 {

    public static void main(String[] args) {
        ScheduledExecutorService executorService = Executors.newScheduledThreadPool(4);
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        Date date = new Date();
        System.out.println("安排执行任务的时间："+sdf.format(date));
        long c2 = date.getTime();
        Callable<String> callable = () -> {
            Date nowDate = new Date();
            System.out.println("****计划任务（2）：【延迟2秒执行，执行结束返回结果】");
            System.out.println("实际执行任务的时间："+sdf.format(nowDate));
            System.out.println("延迟时间："+(nowDate.getTime() - c2)+"ms");
            Thread.sleep(1000);
            System.out.println("任务执行完毕，当前时间："+sdf.format(new Date()));
            return "success";
        };
        ScheduledFuture<String> scheduledFuture = executorService.schedule(callable, 2, TimeUnit.SECONDS);
        try {
            System.out.println("任务的执行结果："+scheduledFuture.get());
        } catch (ExecutionException e1) {
            e1.printStackTrace();
        } catch (InterruptedException e2) {
            e2.printStackTrace();
        }
    }

}

执行结果如下：

安排执行任务的时间：2019-05-28 12:14:05
****计划任务（2）：【延迟2秒执行，执行结束返回结果】
实际执行任务的时间：2019-05-28 12:14:07
延迟时间：2072ms
任务执行完毕，当前时间：2019-05-28 12:14:08
任务的执行结果：success

示例三：延迟+周期性执行任务

package com.java.scheduled.task.pool;

import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;

public class ScheduledTaskDemo03 {

    public static void main(String[] args) {
        ScheduledExecutorService executorService = Executors.newScheduledThreadPool(4);
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        Date date = new Date();
        System.out.println("安排执行任务的时间："+sdf.format(date));
        long c3 = date.getTime();
        Runnable runnable = new Runnable() {
            long exeTime = c3;
            @Override
            public void run() {
                Date nowDate = new Date();
                System.out.println("--------------------------------------------------------------------------------");
                System.out.println("计划任务（3）：【延迟1秒执行第一次任务，之后每过2秒执行一次任务】");
                System.out.println("****实际执行任务的时间："+sdf.format(nowDate));
                System.out.println("****距离上次执行任务的时间间隔："+(nowDate.getTime() - exeTime)+"ms");
                try {
                    Thread.sleep(4000);
                } catch (InterruptedException e) {}
                exeTime = nowDate.getTime();
            }
        };
        executorService.scheduleAtFixedRate(runnable, 1, 2, TimeUnit.SECONDS);
    }

}

执行结果如下：

安排执行任务的时间：2019-05-28 12:15:12
--------------------------------------------------------------------------------
计划任务（3）：【延迟1秒执行第一次任务，之后每过2秒执行一次任务】
****实际执行任务的时间：2019-05-28 12:15:13
****距离上次执行任务的时间间隔：1003ms
--------------------------------------------------------------------------------
计划任务（3）：【延迟1秒执行第一次任务，之后每过2秒执行一次任务】
****实际执行任务的时间：2019-05-28 12:15:17
****距离上次执行任务的时间间隔：4002ms
--------------------------------------------------------------------------------
计划任务（3）：【延迟1秒执行第一次任务，之后每过2秒执行一次任务】
****实际执行任务的时间：2019-05-28 12:15:21
****距离上次执行任务的时间间隔：4001ms
--------------------------------------------------------------------------------
计划任务（3）：【延迟1秒执行第一次任务，之后每过2秒执行一次任务】
****实际执行任务的时间：2019-05-28 12:15:25
****距离上次执行任务的时间间隔：4002ms

示例四：初始延迟+周期性延迟执行任务

package com.java.scheduled.task.pool;

import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;

public class ScheduledTaskDemo04 {

    public static void main(String[] args) {
        ScheduledExecutorService executorService = Executors.newScheduledThreadPool(4);
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        Date date = new Date();
        System.out.println("安排执行任务的时间："+sdf.format(date));
        long c3 = date.getTime();
        Runnable runnable = new Runnable() {
            long exeTime = c3;
            @Override
            public void run() {
                Date nowDate = new Date();
                System.out.println("--------------------------------------------------------------------------------");
                System.out.println("计划任务（4）：【延迟1秒执行第一次任务，之后每过2秒执行一次任务】");
                System.out.println("****实际执行任务的时间："+sdf.format(nowDate));
                System.out.println("****距离上次执行任务的时间间隔："+(nowDate.getTime() - exeTime)+"ms");
                try {
                    Thread.sleep(2500);
                } catch (InterruptedException e) {}
                exeTime = nowDate.getTime();
            }
        };
        executorService.scheduleWithFixedDelay(runnable, 1, 2, TimeUnit.SECONDS);
    }

}

执行结果如下：

安排执行任务的时间：2019-05-28 12:16:56
--------------------------------------------------------------------------------
计划任务（4）：【延迟1秒执行第一次任务，之后每过2秒执行一次任务】
****实际执行任务的时间：2019-05-28 12:16:57
****距离上次执行任务的时间间隔：1018ms
--------------------------------------------------------------------------------
计划任务（4）：【延迟1秒执行第一次任务，之后每过2秒执行一次任务】
****实际执行任务的时间：2019-05-28 12:17:01
****距离上次执行任务的时间间隔：4504ms
--------------------------------------------------------------------------------
计划任务（4）：【延迟1秒执行第一次任务，之后每过2秒执行一次任务】
****实际执行任务的时间：2019-05-28 12:17:06
****距离上次执行任务的时间间隔：4502ms
--------------------------------------------------------------------------------
计划任务（4）：【延迟1秒执行第一次任务，之后每过2秒执行一次任务】
****实际执行任务的时间：2019-05-28 12:17:10
****距离上次执行任务的时间间隔：4502ms