ScheduledExecutorService执行定时任务

编程技术  /  houtizong 发布于 3年前   203

ScheduledExecutorService

 

作者：赵磊

博客：http://elf8848.iteye.com

 

java.util.concurrent.Executors可创建一个线程池，它可给定延迟后定期地执行任务。
Executors.newScheduledThreadPool(int corePoolSize, ThreadFactory threadFactory)

其中的scheduleAtFixedRate 和 scheduleWithFixedDelay 方法可以创建并执行任务，这些任务一直执行 ，并且是可以取消的任务。

 

 

import java.text.SimpleDateFormat;import java.util.Date;import java.util.concurrent.Executors;import java.util.concurrent.ScheduledExecutorService;import java.util.concurrent.ScheduledFuture;import java.util.concurrent.TimeUnit;import java.util.logging.SimpleFormatter;/** * ScheduledExecutorService 测试 *  * @author zhaolei 2012-5-23 */public class ScheduledThreadPoolTest {private final static ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);static SimpleDateFormat sf=new SimpleDateFormat("yyyy-MM-dd dd:mm:ss");/** * beepForTime */public static void beepForTime() {/** * 要执行的任务 */final Runnable beeper = new Runnable() {int i=0;public void run() {System.out.println("beep:"+(i++)+"----"+sf.format(new Date(System.currentTimeMillis())));//throw new RuntimeException();//任务耗时2秒try {Thread.sleep(2000);} catch (InterruptedException e) {e.printStackTrace();}}};int startTime=3;int each=5;System.out.println("任务将于"+startTime+"秒后开始，每"+each+"秒执行1次");/** * 每each秒执行一次任务，两次任务的执行间隔是each秒（前面定义的变更） *  *  * 创建并执行一个在给定初始延迟后首次启用的定期操作，后续操作具有给定的周期； * 也就是将在 initialDelay 后开始执行，然后在 initialDelay+period 后执行， * 接着在 initialDelay + 2 * period 后执行，依此类推。如果任务的任何一个执行遇到异常， * 则后续执行都会被取消。否则，只能通过执行程序的取消或终止方法来终止该任务。 * 如果此任务的任何一个执行要花费比其周期更长的时间，则将推迟后续执行，但不会同时执行。 * 参数： * command - 要执行的任务 * initialDelay - 首次执行的延迟时间 * period - 连续执行之间的周期 * unit - initialDelay 和 period 参数的时间单位  *  *///final ScheduledFuture<?> beeperHandle = scheduler.scheduleAtFixedRate(beeper, startTime, each, TimeUnit.SECONDS);/** *  * 每each秒执行一次任务，两次任务的执行间隔是each秒（前面定义的变更）+任务执行用时 *  * 创建并执行一个在给定初始延迟后首次启用的定期操作， * 随后，在每一次执行终止和下一次执行开始之间都存在给定的延迟。 * 如果任务的任一执行遇到异常，就会取消后续执行。 * 否则，只能通过执行程序的取消或终止方法来终止该任务。  * 参数： * command - 要执行的任务 * initialDelay - 首次执行的延迟时间 * period - 连续执行之间的周期 * unit - initialDelay 和 period 参数的时间单位  *  */final ScheduledFuture<?> beeperHandle = scheduler.scheduleWithFixedDelay(beeper, startTime, each, TimeUnit.SECONDS);/** * 创建并执行在给定延迟后启用的一次性操作。 *  * 这里用于在N时间后取消任务 */scheduler.schedule(new Runnable() {public void run() {System.out.println("取消任务");beeperHandle.cancel(true);}}, 60, TimeUnit.SECONDS);}/** * main *  * @param args */public static void main(String[] args) {beepForTime();}}