Java語(yǔ)言中Timer類的簡(jiǎn)潔用法(二)

2019-11-18 10:49:37

字體：大中小

供稿：網(wǎng)友

　　實(shí)現(xiàn)計(jì)劃框架
　　在上一節(jié)，我們學(xué)習(xí)了如何使用計(jì)劃框架，并將它與 java 定時(shí)器框架進(jìn)行了比較。下面，我將向您展示如何實(shí)現(xiàn)這個(gè)框架。除了清單 3 中展示的 ScheduleIterator 接口，構(gòu)成這個(gè)框架的還有另外兩個(gè)類 —— Scheduler 和 SchedulerTask 。這些類實(shí)際上在內(nèi)部使用 Timer 和 SchedulerTask，因?yàn)橛?jì)劃其實(shí)就是一系列的單次定時(shí)器。
　　
　　清單 5 和 6 顯示了這兩個(gè)類的源代碼：
　　
　　清單 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();
　　　　　　}
　　　　}
　　
　　}
　　就像煮蛋計(jì)時(shí)器，Scheduler 的每一個(gè)實(shí)例都擁有 Timer 的一個(gè)實(shí)例，用于提供底層計(jì)劃。

上一篇：Java語(yǔ)言中Timer類的簡(jiǎn)潔用法(一)

下一篇：簡(jiǎn)單的 Java 循環(huán)控制實(shí)現(xiàn)行列式算法