定制在调度线程池中运行的任务

创建名为MyScheduledTask的类此类由名为V的泛型类型参数化继承FutureTask类且实现RunnableScheduledFuture接口

public class MyScheduledTask extends FutureTask implements RunnableScheduledFuture {

声明名为task的私有RunnableScheduledFuture属性

private RunnableScheduledFuture task;

声明名为executor的私有ScheduledThreadPoolExecutor类

private ScheduledThreadPoolExecutor executor;

声明名为period的私有long属性

private long period;

声明名为startDate的私有long属性

private long startDate;

实现类构造函数接收任务将要执行的Runnable对象任务返回的结果创建MyScheduledTask对象的RunnableScheduledFuture任务和将要执行任务的ScheduledThreadPoolExecutor对象。调用其父类构造函数并存储task和executor属性

public MyScheduledTask(Runnable runnable, V result, RunnableScheduledFuture task, ScheduledThreadPoolExecutor executor) {super(runnable, result);this.tasktask;this.executorexecutor;}

实现getDelay()方法如果任务是周期的且startDate属性值大于零计算实际时间和startDate的差值作为返回值。否则返回task属性中存储的初始任务延迟时间。切记必须在作为参数传递的时间单元中返回结果

Overridepublic long getDelay(TimeUnit unit) {if (!isPeriodic()) {return task.getDelay(unit);} else {if (startDate0){return task.getDelay(unit);} else {Date nownew Date();long delaystartDate-now.getTime();return unit.convert(delay, TimeUnit.MILLISECONDS);}}}

实现compareTo()方法调用初始任务的compareTo()方法

Overridepublic int compareTo(Delayed o) {return task.compareTo(o);}

实现isPerodic()方法调用初始任务的isPerodic()方法

Overridepublic boolean isPeriodic() {return task.isPeriodic();}

实现run()方法如果是周期任务则必须使用任务下次执行的开始时间更新startDate属性属性值为实际时间和周期的总和。然后再次把任务添加到ScheduledThreadPoolExecutor对象队列中

Overridepublic void run() {if (isPeriodic() new Date();startDatenow.getTime()period;executor.getQueue().add(this);}

输出实际时间到控制台调用runAndReset()方法执行此任务然后输出再次执行的实际时间到控制台

System.out.printf("Pre-MyScheduledTask: %s\n",new Date());System.out.printf("MyScheduledTask: Is Periodic: %s\n",isPeriodic());super.runAndReset();System.out.printf("Post-MyScheduledTask: %s\n",new Date());}

实现setPeriod()方法设置任务周期

public void setPeriod(long period) {this.periodperiod;}}

创建名为MyScheduledThreadPoolExecutor的类实现执行MyScheduledTask任务的ScheduledThreadPoolExecutor对象。指定此类继承ScheduledThreadPoolExecutor类

public class MyScheduledThreadPoolExecutor extends ScheduledThreadPoolExecutor{

实现只调用父类构造函数的类构造函数

public MyScheduledThreadPoolExecutor(int corePoolSize) {super(corePoolSize);}

实现decorateTask()方法将待执行的Runnable对象和执行此对象的RunnableScheduledFuture任务作为参数接收创建并返回MyScheduledTask任务使用这些对象来构造它们

Overrideprotected RunnableScheduledFuture decorateTask(Runnable runnable, RunnableScheduledFuture task) {MyScheduledTask myTasknew MyScheduledTask(runnable, null, task,this);return myTask;}

重写scheduledAtFixedRate()方法调用其父类方法将返回对象转换成MyScheduledTask对象使用setPeriod()方法设置任务的周期

Overridepublic ScheduledFuture scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit) {ScheduledFuture task super.scheduleAtFixedRate(command, initialDelay, period, unit);MyScheduledTask myTask(MyScheduledTask)task;myTask.setPeriod(TimeUnit.MILLISECONDS.convert(period,unit));return task;}}

创建名为Task的类实现Runnable接口

public class Task implements Runnable {

实现run()方法输出任务启动信息设置当前线程休眠2秒钟然后输出任务结束信息

Overridepublic void run() {System.out.printf("Task: Begin.\n");try {TimeUnit.SECONDS.sleep(2);} catch (InterruptedException e) {e.printStackTrace();}System.out.printf("Task: End.\n");}}

通过创建名为Main的类添加main()方法实现本范例主类

public class Main {public static void main(String[] args) throws Exception{

创建名为executor的MyScheduledThreadPoolExecutor对象使用4作为参数池中包含两个线程

MyScheduledThreadPoolExecutor executornew MyScheduledThreadPoolExecutor(4);

创建名为task的Task对象输出实际时间到控制台

Task tasknew Task();System.out.printf("Main: %s\n",new Date());

使用schedule()方法发送延迟任务到执行器此任务将延迟1秒后执行

executor.schedule(task, 1, TimeUnit.SECONDS);

设置主线程休眠3秒钟

TimeUnit.SECONDS.sleep(3);

创建另一个Task对象再次输出实际时间到控制台

tasknew Task();System.out.printf("Main: %s\n",new Date());

使用scheduleAtFixedRate()方法发送周期任务到执行器此任务将延迟1秒后执行且每3秒钟执行一次

executor.scheduleAtFixedRate(task, 1, 3, TimeUnit.SECONDS);

设置主线程休眠10秒钟

TimeUnit.SECONDS.sleep(10);

使用shutdown()方法关闭执行器使用awaitTermination()方法等待执行器结束

executor.shutdown();executor.awaitTermination(1, TimeUnit.DAYS);

输出指明程序结束的信息到控制台

System.out.printf("Main: End of the program.\n");}}