Java語言中Timer類的簡潔用法(二)

2019-11-18 10:49:37

字體：大中小

來源：轉載

供稿：網友

　　實現計劃框架
　　在上一節，我們學習了如何使用計劃框架，并將它與 java 定時器框架進行了比較。下面，我將向您展示如何實現這個框架。除了清單 3 中展示的 ScheduleIterator 接口，構成這個框架的還有另外兩個類 —— Scheduler 和 SchedulerTask 。這些類實際上在內部使用 Timer 和 SchedulerTask，因為計劃其實就是一系列的單次定時器。
　　
　　清單 5 和 6 顯示了這兩個類的源代碼：
　　
　　清單 5. Scheduler
　　
　　package org.tiling.scheduling;
　　
　　import java.util.Date;
　　import java.util.Timer;
　　import java.util.TimerTask;
　　
　　public class Scheduler {
　　
　　　　class SchedulerTimerTask extends TimerTask {
　　　　　　PRivate SchedulerTask schedulerTask;
　　　　　　private ScheduleIterator iterator;
　　　　　　public SchedulerTimerTask(SchedulerTask schedulerTask,
　　　　　　　　　　ScheduleIterator iterator) {
　　　　　　　　this.schedulerTask = schedulerTask;
　　　　　　　　this.iterator = iterator;
　　　　　　}
　　　　　　public void run() {
　　　　　　　　schedulerTask.run();
　　　　　　　　reschedule(schedulerTask, iterator);
　　　　　　}
　　　　}
　　
　　　　private final Timer timer = new Timer();
　　
　　　　public Scheduler() {
　　　　}
　　
　　　　public void cancel() {
　　　　　　timer.cancel();
　　　　}
　　
　　　　public void schedule(SchedulerTask schedulerTask,
　　　　　　　　ScheduleIterator iterator) {
　　
　　　　　　Date time = iterator.next();
　　　　　　if (time == null) {
　　　　　　　　schedulerTask.cancel();
　　　　　　} else {
　　　　　　　　synchronized(schedulerTask.lock) {
　　　　　　　　　　if (schedulerTask.state != SchedulerTask.VIRGIN) {
　　　　　　　　　　　throw new IllegalStateException("Task already
　　　　　　　　　　　scheduled " + "or cancelled");
　　　　　　　　　　}
　　　　　　　　　　schedulerTask.state = SchedulerTask.SCHEDULED;
　　　　　　　　　　schedulerTask.timerTask =
　　　　　　　　　　　　new SchedulerTimerTask(schedulerTask, iterator);
　　　　　　　　　　timer.schedule(schedulerTask.timerTask, time);
　　　　　　　　}
　　　　　　}
　　　　}
　　
　　　　private void reschedule(SchedulerTask schedulerTask,
　　　　　　　　ScheduleIterator iterator) {
　　
　　　　　　Date time = iterator.next();
　　　　　　if (time == null) {
　　　　　　　　schedulerTask.cancel();
　　　　　　} else {
　　　　　　　　synchronized(schedulerTask.lock) {
　　　　　　　　　　if (schedulerTask.state != SchedulerTask.CANCELLED) {
　　　　　　　　　　　　schedulerTask.timerTask =
　　　　　　　　　　　　　　new SchedulerTimerTask(schedulerTask, iterator);
　　　　　　　　　　　　timer.schedule(schedulerTask.timerTask, time);
　　　　　　　　　　}
　　　　　　　　}
　　　　　　}
　　　　}
　　
　　}
　　
　　清單 6 顯示了 SchedulerTask 類的源代碼：
　　
　　package org.tiling.scheduling;
　　
　　import java.util.TimerTask;
　　
　　public abstract class SchedulerTask implements Runnable {
　　
　　　　final Object lock = new Object();
　　
　　　　int state = VIRGIN;
　　　　static final int VIRGIN = 0;
　　　　static final int SCHEDULED = 1;
　　　　static final int CANCELLED = 2;
　　
　　　　TimerTask timerTask;
　　
　　　　protected SchedulerTask() {
　　　　}
　　
　　　　public abstract void run();
　　
　　　　public boolean cancel() {
　　　　　　synchronized(lock) {
　　　　　　　　if (timerTask != null) {
　　　　　　　　　　timerTask.cancel();
　　　　　　　　}
　　　　　　　　boolean result = (state == SCHEDULED);
　　　　　　　　state = CANCELLED;
　　　　　　　　return result;
　　　　　　}
　　　　}
　　
　　　　public long scheduledExecutionTime() {
　　　　　　synchronized(lock) {
　　　　　　 return timerTask == null ? 0 : timerTask.scheduledExecutionTime();
　　　　　　}
　　　　}
　　
　　}
　　就像煮蛋計時器，Scheduler 的每一個實例都擁有 Timer 的一個實例，用于提供底層計劃。

上一篇：Java語言中Timer類的簡潔用法(一)

下一篇：簡單的 Java 循環控制實現行列式算法