线程池工厂方法newScheduledThreadPool(),计划任务

时间:2022-02-28 05:56:37
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
......
...
.