JAVA 线程池ScheduledThreadPoolExecutor中scheduleAtFixedRate和scheduleWithFixedDelay比较

桃扇骨 2022-05-13 11:44 242阅读 0赞

一般知道Jdk中线程池ScheduledThreadPoolExecutor用来跑定时任务，注意到其中由两个方法scheduleAtFixedRate和scheduleWithFixedDelay，两方法的参数内容一样，方法名字也很像，含义也很像，它两有什么不同呢？

public ScheduledFuture<?> scheduleWithFixedDelay(Runnable command,
                                                         long initialDelay,
                                                         long delay,
                                                         TimeUnit unit);
    
    public ScheduledFuture<?> scheduleAtFixedRate(Runnable command,
                                                      long initialDelay,
                                                      long period,
                                                      TimeUnit unit)

先看Jdk1.8的注释：

> scheduleAtFixedRate：
> 
> Creates and executes a periodic action that becomes enabled firstafter  
> the given initial delay, and subsequently with the givenperiod; that  
> is executions will commence after initialDelay then  
> initialDelay+period, then initialDelay + 2 \* period, and so on.If any  
> execution of the taskencounters an exception, subsequent executions  
> are suppressed.Otherwise, the task will only terminate via  
> cancellation ortermination of the executor. If any execution of this  
> tasktakes longer than its period, then subsequent executionsmay start  
> late, but will not concurrently execute.

理解意思：  
创建一个定期的任务，这个任务将在给定的initial delay后开始执行，并且依次在给定的间隔时间后执行，即依次会在initialDelay、initialDelay+period、 initialDelay + 2 \* period，以此类推。如果哪个任务执行时候发生了异常，后续就不会在执行任务了，不然的话，任务只能通过cancel来进行取消。如果一个任务的执行时间超过了间隔时间，那么下一次任务执行将会被推迟，两个任务不会同时并非执行。

> scheduleWithFixedDelay：
> 
> Creates and executes a periodic action that becomes enabled firstafter  
> the given initial delay, and subsequently with thegiven delay between  
> the termination of one execution and thecommencement of the next. If  
> any execution of the taskencounters an exception, subsequent  
> executions are suppressed.Otherwise, the task will only terminate via

理解意思：  
创建一个定期执行的任务在initialDelay时间之后开始执行，以后每个任务执行都是在上一个任务完成后的delay时间后才开始执行，如果一个任务执行抛了异常，所有任务都会停止，不然只能通过cancel取消任务的执行

总结如下：  
1. scheduleAtFixedRate和scheduleWithFixedDelay都是在初始delay后开始执行，  
2. scheduleAtFixedRate每次任务执行的时间理论上是固定的，不算任务执行的时间，依次是initialDelay、initialDelay+period、 initialDelay + 2 \* period定点执行任务，如果一次任务的执行消耗时间过多，将延后下个任务执行；  
3. 在这点上scheduleWithFixedDelay不一样，scheduleWithFixedDelay是下次任务的执行是在上次任务执行完成后的delay时间后开始。  
4. 两者在任务抛异常后都会终止任务执行，另外通过cancel也可以终止任务执行。

两者代码上非常像，只有初始化的SheduleFutureTask参数不一样

scheduleAtFixedRate：
    
    ScheduledFutureTask<Void> sft =
                new ScheduledFutureTask<Void>(command,
                                              null,
                                              triggerTime(initialDelay, unit),
                                              unit.toNanos(period));
    
    scheduleWithFixedDelay：
    
    ScheduledFutureTask<Void> sft =
                new ScheduledFutureTask<Void>(command,
                                              null,
                                              triggerTime(initialDelay, unit),
                                              unit.toNanos(-delay));

ScheduledFutureTask中与时间相关的方法主要是setNextRunTime，用来设置下个任务运行时间，time为任务开始执行的时间，period为传入的间隔时间；当p>0时，对应的是scheduleAtFixedRate的情况，这时候下次执行时间为上次任务开始时间加上间隔时间period；当p<0时，对应的是scheduleWithFixedDelay，看上去不太一样，下次运行时间是triggerTime(-p)，负负得正，其实就是当前时间加上间隔时间。setNextRunTime（）这个方法的执行时间是runAndReset()的时候，其实就是任务完成的时候执行。

/** * Sets the next time to run for a periodic task. */
          private void setNextRunTime() {
              long p = period;
              if (p > 0)
                  time += p;
              else
                  time = triggerTime(-p);
          }
    
        /** * Returns the trigger time of a delayed action. */
        long triggerTime(long delay) {
            return now() +
                ((delay < (Long.MAX_VALUE >> 1)) ? delay : overflowFree(delay));
        }