您的位置：首页 > 其它

ScheduledExecutorService执行周期性或定时任务

2012-11-27 21:43 489 查看

ScheduledExecutorService扩展了ExecutorService接口，提供时间排程的功能。

schedule(Callable<V> callable, long delay, TimeUnit unit)

创建并执行在给定延迟后启用的 ScheduledFuture。

schedule(Runnable command, long delay, TimeUnit unit)

创建并执行在给定延迟后启用的一次性操作。

scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnitunit)

创建并执行一个在给定初始延迟后首次启用的定期操作，后续操作具有给定的周期；也就是将在 initialDelay 后开始执行，然后在initialDelay+period 后执行，接着在 initialDelay + 2 * period 后执行，依此类推。

scheduleWithFixedDelay(Runnable command, long initialDelay, long delay,TimeUnit unit)

创建并执行一个在给定初始延迟后首次启用的定期操作，随后，在每一次执行终止和下一次执行开始之间都存在给定的延迟。

schedule方法被用来延迟指定时间来执行某个指定任务。如果你需要周期性重复执行定时任务可以使用scheduleAtFixedRate或者scheduleWithFixedDelay方法，它们不同的是前者以固定频率执行，后者以相对固定频率执行。

不管任务执行耗时是否大于间隔时间，scheduleAtFixedRate和scheduleWithFixedDelay都不会导致同一个任务并发地被执行。唯一不同的是scheduleWithFixedDelay是当前一个任务结束的时刻，开始结算间隔时间，如0秒开始执行第一次任务，任务耗时5秒，任务间隔时间3秒，那么第二次任务执行的时间是在第8秒开始。

ScheduledExecutorService的实现类，是ScheduledThreadPoolExecutor。ScheduledThreadPoolExecutor对象包含的线程数量是没有可伸缩性的，只会有固定数量的线程。不过你可以通过其构造函数来设定线程的优先级，来降低定时任务线程的系统占用。

特别提示：通过ScheduledExecutorService执行的周期任务，如果任务执行过程中抛出了异常，那么过ScheduledExecutorService就会停止执行任务，且也不会再周期地执行该任务了。所以你如果想保住任务都一直被周期执行，那么catch一切可能的异常。

最简单使用：

public class SimpleTest {

public static void main(String[] args) {

ScheduledExecutorService service=Executors.newScheduledThreadPool(2);

Runnable task1=new Runnable()
{
public void run()
{
System.out.println("task repeated");

}
};
service.scheduleAtFixedRate(task1, 10, 20,TimeUnit.SECONDS);

}

}

使用

public interface ScheduledFuture<V>extends Delayed, Future<V>

A delayed result-bearing action that can be cancelled. Usually a scheduled future is the result of scheduling a task with a

ScheduledExecutorService

.

beep every ten seconds for an hour 执行某个方法在一个小时内每个10秒:

package ExecutorService;

import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledFuture;
import java.util.concurrent.TimeUnit;

public class BeeperControl {
private final static ScheduledExecutorService scheduler=Executors.newScheduledThreadPool(1);

private  static int count=0;
public static void beepForAnHour()
{
final Runnable beeper=new Runnable(){
public void run()
{
System.out.println(count++);
}
};
final ScheduledFuture<?> beeperHandle =
scheduler.scheduleAtFixedRate(beeper, 10, 10, TimeUnit.SECONDS);

scheduler.schedule(new Runnable() {

public void run()
{
beeperHandle.cancel(true);
}
}, 60 * 60, TimeUnit.SECONDS);

}

public static void main(String[] args) {
beepForAnHour();

}

}

深入：http://victorzhzh.iteye.com/blog/1011635

内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理

标签：

相关文章推荐

新的分享

章节导航