package com.thread.test.ThreadPool; import java.util.concurrent.Executors; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.TimeUnit; public class ScheduledExecutorServiceDemo { public static void main(String[] args) { ScheduledExecutorService ses = Executors.newScheduledThreadPool(10); // scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit)任务调度的频率是一定的 // 任务开始于给定的初始延时时间initialDelay,后续任务将会按照给定的周期period进行:后续第一个任务将会在initialDelay+period时执行, // 后续第二个任务将在initialDelay+2*period时执行,以此类推 // scheduleWithFixedDelay(Runnable command, long initialDelay, long delay, TimeUnit unit) // 任务开始于给定的初始延时时间initialDelay,后续任务将会按照给定的延时delay进行,即上一个任务的结束时间到下一个任务的开始时间的时间差 ses.scheduleAtFixedRate(new Runnable() { public void run() { try { Thread.sleep(1000);// 模拟任务的执行时间是1s // 如果调度周期是2s,任务的执行时间是8s,那么任务的执行周期会变成8s // 如果调度周期是2s,任务的执行时间是1s,那么任务的执行周期就是设置的2s System.out.println(System.currentTimeMillis() / 1000 + "s"); } catch (InterruptedException e) { e.printStackTrace(); // 如果任务遇到异常,那么后续的所有子任务都会停止调度,因此,必须保证异常被及时处理,为周期性任务的稳定调度提供条件 } } }, 0, 2, TimeUnit.SECONDS); // 任务开始于给定的初始延时时间--0s,后续任务将会按照给定的周期--2s进行:后续第一个任务将会在initialDelay+period--2s时执行, // 后续第二个任务将在initialDelay+2*period--4s时执行,以此类推 } }
使用scheduleAtFixedRate()方法调度任务,输出如下:
1516775766s
1516775768s
1516775770s
1516775772s
1516775774s
1516775776s
1516775778s
.......
...
.
使用scheduleWithFixedDelay()方法调度任务,输出如下:
1516775824s
1516775827s
1516775830s
1516775833s
1516775836s
1516775839s
......
...
.