多线程之ScheduledExecutorService

一：接口方法

ScheduleExecutorService接口中有四个重要的方法，其中scheduleAtFixedRate和scheduleWithFixedDelay在实现定时程序时比较方便。

下面是该接口的原型定义

java.util.concurrent.ScheduleExecutorService extends ExecutorService extends Executor



接口scheduleAtFixedRate原型定义及参数说明

[java] view
plaincopy

public ScheduledFuture<?> scheduleAtFixedRate(Runnable command,  

            long initialDelay,  

            long period,  

            TimeUnit unit);  

command：执行线程

initialDelay：初始化延时

period：两次开始执行最小间隔时间

unit：计时单位
接口scheduleWithFixedDelay原型定义及参数说明

[java] view
plaincopy

public ScheduledFuture<?> scheduleWithFixedDelay(Runnable command,  

                long initialDelay,  

                long delay,  

                TimeUnit unit);  

command：执行线程

initialDelay：初始化延时

period：前一次执行结束到下一次执行开始的间隔时间（间隔执行延迟时间）

unit：计时单位

二：实例

public class ScheduledExecutorServiceTest {

private ScheduledExecutorService executor = Executors.newScheduledThreadPool(2);

public void startNormal(){
executor.scheduleWithFixedDelay(new Runnable() {
@Override
public void run() {
System.out.println("执行定时任务");
}
}, 1000*1, 5*1000, TimeUnit.MILLISECONDS);//延迟1秒后执行，执行周期为5s执行依次
}

public void startException(){
executor.scheduleWithFixedDelay(new Runnable() {
@Override
public void run() {
throw new RuntimeException();
}
}, 1000*1, 5*1000, TimeUnit.MILLISECONDS);//延迟1秒后执行，执行周期为5s执行依次

}

public static void main(String[] args) throws InterruptedException{
ScheduledExecutorServiceTest schedule = new ScheduledExecutorServiceTest();
schedule.startException();
Thread.sleep(5*1000);
schedule.startNormal();
}
}

三：与Timer的对比

java.util.Timer计时器有管理任务延迟执行("如1000ms后执行任务")以及周期性执行("如每500ms执行一次该任务")。但是，Timer存在一些缺陷，因此你应该Timer对调度的支持是基于绝对时间,而不是相对时间的，由此任务对系统时钟的改变是敏感的，而ScheduledThreadExecutor只支持相对时间。

Timer的另一个问题在于，如果TimerTask抛出未检查的异常，Timer将会产生无法预料的行为。Timer线程并不捕获异常，所以TimerTask抛出的未检查的异常会终止timer线程。这种情况下，Timer也不会再重新恢复线程的执行了;它错误的认为整个Timer都被取消了。此时，已经被安排但尚未执行的TimerTask永远不会再执行了，新的任务也不能被调度了。

例子：

<span style="font-size:14px;">public class TimerSchedule {
private Timer timer = new Timer();
public void startNormal(){
timer.schedule(new TimerTask() {
@Override
public void run() {
System.out.println("执行定时任务");
}
}, 1000*1, 5*1000);//延迟1秒后执行，执行周期为5s执行依次
}

public void startException(){
timer.schedule(new TimerTask() {

@Override
public void run() {
throw new RuntimeException();
}
}, 1000*1, 5*1000);//延迟1秒后执行，执行周期为5s执行依次

}

public static void main(String[] args) throws InterruptedException{
TimerSchedule schedule = new TimerSchedule();
schedule.startException();
Thread.sleep(5*1000);
schedule.startNormal();
}
}</span>运行该程序，Timer会抛出一个RumtimeException和java.lang.IllegalStateException:Timer already cancelled.

你可能希望程序会一直运行下去，然而实际情况如程序所示5秒钟后就中止了，还伴随着一个异常，异常的消息是"Timer already cancelled"。ScheduledThreadPoolExector妥善地处理了这个异常的任务，所以说在java5.0或更高的JDK中，几乎没有理由再使用Timer了。