import commonj.timers.Timer; //导入依赖的package包/类
@Override
public void afterPropertiesSet() throws NamingException {
	super.afterPropertiesSet();
	if (this.scheduledTimerListeners != null) {
		TimerManager timerManager = getTimerManager();
		for (ScheduledTimerListener scheduledTask : this.scheduledTimerListeners) {
			Timer timer;
			if (scheduledTask.isOneTimeTask()) {
				timer = timerManager.schedule(scheduledTask.getTimerListener(), scheduledTask.getDelay());
			}
			else {
				if (scheduledTask.isFixedRate()) {
					timer = timerManager.scheduleAtFixedRate(
							scheduledTask.getTimerListener(), scheduledTask.getDelay(), scheduledTask.getPeriod());
				}
				else {
					timer = timerManager.schedule(
							scheduledTask.getTimerListener(), scheduledTask.getDelay(), scheduledTask.getPeriod());
				}
			}
			this.timers.add(timer);
		}
	}
}
 

import commonj.timers.Timer; //导入依赖的package包/类
/**
 * Cancels all statically registered Timers on shutdown,
 * and stops the underlying TimerManager (if not shared).
 * @see commonj.timers.Timer#cancel()
 * @see commonj.timers.TimerManager#stop()
 */
@Override
public void destroy() {
	// Cancel all registered timers.
	for (Timer timer : this.timers) {
		try {
			timer.cancel();
		}
		catch (Throwable ex) {
			logger.warn("Could not cancel CommonJ Timer", ex);
		}
	}
	this.timers.clear();

	// Stop the TimerManager itself.
	super.destroy();
}
 

import commonj.timers.Timer; //导入依赖的package包/类
public void afterPropertiesSet() throws NamingException {
	super.afterPropertiesSet();
	if (this.scheduledTimerListeners != null) {
		TimerManager timerManager = getTimerManager();
		for (ScheduledTimerListener scheduledTask : this.scheduledTimerListeners) {
			Timer timer;
			if (scheduledTask.isOneTimeTask()) {
				timer = timerManager.schedule(scheduledTask.getTimerListener(), scheduledTask.getDelay());
			}
			else {
				if (scheduledTask.isFixedRate()) {
					timer = timerManager.scheduleAtFixedRate(
							scheduledTask.getTimerListener(), scheduledTask.getDelay(), scheduledTask.getPeriod());
				}
				else {
					timer = timerManager.schedule(
							scheduledTask.getTimerListener(), scheduledTask.getDelay(), scheduledTask.getPeriod());
				}
			}
			this.timers.add(timer);
		}
	}
}
 

import commonj.timers.Timer; //导入依赖的package包/类
@Override
public ScheduledFuture<?> schedule(Runnable task, Date startTime) {
	TimerScheduledFuture futureTask = new TimerScheduledFuture(errorHandlingTask(task, false));
	Timer timer = getTimerManager().schedule(futureTask, startTime);
	futureTask.setTimer(timer);
	return futureTask;
}
 

import commonj.timers.Timer; //导入依赖的package包/类
@Override
public ScheduledFuture<?> scheduleAtFixedRate(Runnable task, Date startTime, long period) {
	TimerScheduledFuture futureTask = new TimerScheduledFuture(errorHandlingTask(task, true));
	Timer timer = getTimerManager().scheduleAtFixedRate(futureTask, startTime, period);
	futureTask.setTimer(timer);
	return futureTask;
}
 

import commonj.timers.Timer; //导入依赖的package包/类
@Override
public ScheduledFuture<?> scheduleWithFixedDelay(Runnable task, Date startTime, long delay) {
	TimerScheduledFuture futureTask = new TimerScheduledFuture(errorHandlingTask(task, true));
	Timer timer = getTimerManager().schedule(futureTask, startTime, delay);
	futureTask.setTimer(timer);
	return futureTask;
}
 

import commonj.timers.Timer; //导入依赖的package包/类
@Override
public void timerExpired(Timer timer) {
	Date actualExecutionTime = new Date();
	super.timerExpired(timer);
	Date completionTime = new Date();
	this.triggerContext.update(this.scheduledExecutionTime, actualExecutionTime, completionTime);
	if (!this.cancelled) {
		schedule();
	}
}
 

import commonj.timers.Timer; //导入依赖的package包/类
public void timerExpired(Timer timer) {
  System.out.println("timer expired called on " + timer);
  // some useful work here ...
  // let's just cancel the timer
  System.out.println("cancelling timer ...");
  timer.cancel();
}
 

import commonj.timers.Timer; //导入依赖的package包/类
public synchronized Timer schedule(TimerListener listener, Date when) throws IllegalArgumentException,
    IllegalStateException {

    DefaultTimerTask task = new DefaultTimerTask(timerCount++, listener);
    timers.put(timerCount, task);

    // schedule to fire
    timer.schedule(task, when);

    return task;
}
 

import commonj.timers.Timer; //导入依赖的package包/类
/**
 * Invoked when the time has elapsed.
 * 
 * @param timer timer reference
 * 
 * @see commonj.timers.TimerListener#timerExpired(commonj.timers.Timer)
 */
public void timerExpired(Timer timer) {
    LOG.debug(name + " fired on " + DateTimeUtility.toString(getScheduledTime()));

    try {
        updater.execute();
    }
    catch (Throwable t) {
        LOG.error("Error encountered during scheduled FDB-DIF update process", t);
    }

    scheduleNextTimer(); // schedule next timer event
}
 

import commonj.timers.Timer; //导入依赖的package包/类
/**
 * Delegates execution to the underlying Runnable.
 */
@Override
public void timerExpired(Timer timer) {
	this.runnable.run();
}
 

import commonj.timers.Timer; //导入依赖的package包/类
public void setTimer(Timer timer) {
	this.timer = timer;
}
 

import commonj.timers.Timer; //导入依赖的package包/类
/**
 * Delegates execution to the underlying Runnable.
 */
public void timerExpired(Timer timer) {
	this.runnable.run();
}
 

import commonj.timers.Timer; //导入依赖的package包/类
public ScheduledFuture schedule(Runnable task, Date startTime) {
	TimerScheduledFuture futureTask = new TimerScheduledFuture(errorHandlingTask(task, false));
	Timer timer = getTimerManager().schedule(futureTask, startTime);
	futureTask.setTimer(timer);
	return futureTask;
}
 

import commonj.timers.Timer; //导入依赖的package包/类
public ScheduledFuture scheduleAtFixedRate(Runnable task, Date startTime, long period) {
	TimerScheduledFuture futureTask = new TimerScheduledFuture(errorHandlingTask(task, true));
	Timer timer = getTimerManager().scheduleAtFixedRate(futureTask, startTime, period);
	futureTask.setTimer(timer);
	return futureTask;
}
 

import commonj.timers.Timer; //导入依赖的package包/类
public ScheduledFuture scheduleWithFixedDelay(Runnable task, Date startTime, long delay) {
	TimerScheduledFuture futureTask = new TimerScheduledFuture(errorHandlingTask(task, true));
	Timer timer = getTimerManager().schedule(futureTask, startTime, delay);
	futureTask.setTimer(timer);
	return futureTask;
}
 

import commonj.timers.Timer; //导入依赖的package包/类
public synchronized Timer scheduleAtFixedRate(TimerListener arg0, Date arg1, long arg2)
    throws IllegalArgumentException, IllegalStateException {
    throw new UnsupportedOperationException();
}