scheduler.java.svn-base

这个是我做j2ee培训时候自己整理和编写的设计模式的学习例子

package org.hyq.observer1;

import java.util.LinkedList;
import java.util.Queue;

public class Scheduler extends Thread {

	private Queue<Action> actions = new LinkedList<Action>();
	private boolean isRunning = true;

	@Override
	public synchronized void run() {
		while (isRunning) {
			while (!actions.isEmpty()) {
				Action action = actions.remove();
				action.observer.doAction(action.observable, action.arg);
			}
			try {
				wait();
			} catch (InterruptedException ex) {
			}
		}
	}

	void addAction(Action action) {
		if (isRunning) {
			actions.add(action);
		}
	}

	void setStopFlag() {
		isRunning = false;
	}

}