ScheduledExecutorService的简单使用、scheduleAtFixedRate和scheduleWithFixedDelay区别

ScheduledExecutorService

JAVA用于执行周期性任务的线程池：
ScheduledExecutorService
ScheduledExecutorService的继承关系

执行周期性任务的两个方法

• scheduleAtFixedRate
• scheduleWithFixedDelay

方法介绍

1、scheduleAtFixedRate

public ScheduledFuture<?> scheduleAtFixedRate(Runnable command,
                                                  long initialDelay,
                                                  long period,
                                                  TimeUnit unit);
1
2
3
4

• Runnable command 任务对象，Runnable 及其子类
• long initialDelay 任务开始执行的延迟时间
• long period 任务执行的间隔周期 例如 1s 10min 1h 等
• TimeUnit unit 任务执行周期的时间单位

示例：每隔1s打印一次hello world

@Slf4j
public class ThreadTest {
    private static ScheduledExecutorService executorService = new ScheduledThreadPoolExecutor(1);
    public static void main(String[] args) {
        log.info("task begin");
        executorService.scheduleAtFixedRate(() -> {
            log.info("hello world !");
        }, 1, 1, TimeUnit.SECONDS);
    }
}
1
2
3
4
5
6
7
8
9
10

运行结果：

2、scheduleWithFixedDelay

public ScheduledFuture<?> scheduleWithFixedDelay(Runnable command,
                                                     long initialDelay,
                                                     long delay,
                                                     TimeUnit unit);
1
2
3
4

• Runnable command 任务对象
• long initialDelay 任务开始执行的延迟时间
• long period 任务执行的间隔周期 例如 1s 10min 1h 等
• TimeUnit unit 任务执行周期的时间单位

示例：每隔1s打印一次hello world

@Slf4j
public class ThreadTest {
    private static ScheduledExecutorService executorService = new ScheduledThreadPoolExecutor(1);
    public static void main(String[] args) {
        log.info("task begin");
        executorService.scheduleWithFixedDelay(() -> {
            log.info("hello world !");
        }, 1, 1, TimeUnit.SECONDS);
    }
}
1
2
3
4
5
6
7
8
9
10

运行结果：

3、区别与联系

• 两个方法都可以执行周期性的任务，在任务执行时间比较短时，小于任务执行周期的时候，两者几乎看不出什么区别

• 当任务执行时间大于任务执行周期的时候，如下案例

  我们让两个方法执行周期都是1s，任务执行时间变成2s

@Slf4j
public class ThreadTest {
    private static ScheduledExecutorService executorService = new ScheduledThreadPoolExecutor(1);
    public static void main(String[] args) {
        log.info("task begin");
        executorService.scheduleAtFixedRate(() -> {
            log.info("hello world !");
            try {
                Thread.sleep(2000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }, 1, 1, TimeUnit.SECONDS);
    }
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

执行结果：

@Slf4j
public class ThreadTest {
    private static ScheduledExecutorService executorService = new ScheduledThreadPoolExecutor(1);
    public static void main(String[] args) {
        log.info("task begin");
        executorService.scheduleWithFixedDelay(() -> {
            log.info("hello world !");
            try {
                Thread.sleep(2000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }, 1, 1, TimeUnit.SECONDS);
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

执行结果：

4、总结：

• 可以看到 scheduleAtFixedRate 是从上个任务开始的时间计时，如果任务的执行时间小于任务的周期，则任务周期到了之后立即执行下个任务；如果执行任务的时间大于任务的执行周期，这时候的任务执行时间会覆盖任务的执行周期，真正的间隔时间变成了任务的执行时间
• scheduleWithFixedDelay是等待上一个任务结束时才开始计时