更新されるように、オブジェクト間の１対多数の依存関係を定義します。
ある Subject の状態が変化したときに別の Subject の状態を変更したい場合、
一度 Observer に通知し、Observer が関係する Subject の変更を行います。
void client() throws InterruptedException {
ConcreteSubject subject = new ConcreteSubject();
Observer observer = new ConcreteObserver();
subject.addObserver(observer);
// スレッド内で実行
Thread subjectThread = new Thread(subject);
subjectThread.start();
subjectThread.join();
}
interface Subject {
public void addObserver(Observer observer);
public void _notify();
}
interface Observer {
public void update();
}
class ConcreteSubject implements Subject, Runnable {
private List<Observer> observers = new CopyOnWriteArrayList<Observer>();
public void addObserver(Observer observer) {
this.observers.add(observer);
}
public void _notify() {
for (Observer observer: this.observers) {
observer.update();
}
}
public void run() {
this._notify();
}
}
class ConcreteObserver implements Observer {
public void update() {
System.out.println("update");
}
}
実行結果:update
サンプルプログラムは、ダイアログの例です。ここではダイアログが Observer、ボタン・テキストボックス・リストといった部品が Subject に相当
します。
テキストを入力して Add ボタンを押すとリストに追加されますが、Subject である部品がほかの
部品を直接操作することはせず、一度 Observer であるダイアログを介して操作を行います。
Add ボタンを押す -> Button.processActionEvent(Subject.needsAdvice() に相当)
-> Dialog_ConcreteObserver.actionPerformed()(ConcreteObserver.consultation() に相当)
-> テキストボックスのテキストを取得し、リストに追加(ConcreteSubject.advice() に相当)
ボタン->ダイアログへの呼び出しは、標準ライブラリの Button クラスが行っています。
Button.addActionListener() によって ActionListener インターフェースを実装したダイアログを
登録することで、ボタンでアクションイベントが発生した際に
Dialog_ConcreteObserver.actionPerformed() が呼び出されます。
また、addWindowsListener ... の部分も Observer パターンで、WindowAdapter が Observer、
ダイアログが Subject に相当します。
実行結果:
dialog.actionPerformed(): from button0
dialog.actionPerformed(): from button0
dialog.actionPerformed(): from list0
dialog.actionPerformed(): from button1
package design_pattern;
import java.awt.Button;
import java.awt.Component;
import java.awt.Frame;
import java.awt.List;
import java.awt.TextField;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.WindowAdapter;
import java.awt.event.WindowEvent;
/**
* Observer
* GoF, Code Complete
*
* １つのオブジェクトの状態が変化したとき、全ての依存するオブジェクトに通知され自動的に
* 更新されるように、オブジェクト間の１対多数の依存関係を定義します。
*
* @author 2015/06/21 matsushima
*/
public class ObserverSample {
public static void main(String[] args) throws InterruptedException {
// ConcreteObserver: dialog
Dialog_ConcreteObserver dialog = new ObserverSample().new Dialog_ConcreteObserver();
dialog.setVisible(true);
}
/** ConcreteObserver: ダイアログ。 */
public class Dialog_ConcreteObserver extends Frame implements ActionListener {
private static final long serialVersionUID = 1L;
private TextField text;
private List list;
private Button buttonAdd, buttonClose;
public Dialog_ConcreteObserver() {
super("ObserverSample");
setLayout(null);
addWindowListener(new WindowAdapter() { // Subject.addObserver に相当。
public void windowClosing(WindowEvent e) { // ConcreteObserver.update() に相当。
System.exit(0);
}
});
this.setSize(290, 230);
// ConcreteSubject: text
text = new TextField();
text.setBounds(20, 50, 200, 25);
text.addActionListener(this); // Subject.addObserver に相当。
this.add(text);
// ConcreteSubject: buttonAdd
buttonAdd = new Button("Add");
buttonAdd.setBounds(220, 50, 50, 25);
buttonAdd.addActionListener(this); // Subject.addObserver に相当。
this.add(buttonAdd);
// ConcreteSubject: list
list = new List(5);
list.setBounds(20, 80, 250, 100);
list.addActionListener(this); // Subject.addObserver に相当。
this.add(list);
// ConcreteSubject: buttonClose
buttonClose = new Button("Close");
buttonClose.setBounds(220, 185, 50, 25);
buttonClose.addActionListener(this); // Subject.addObserver に相当。
this.add(buttonClose);
}
/** ConcreteObserver.update() に相当。 */
public void actionPerformed(ActionEvent e) {
//System.out.println(e);
System.out.println("dialog.actionPerformed(): from " + ((Component)e.getSource()).getName());
if (this.buttonAdd == e.getSource() // buttonAdd click
|| this.text == e.getSource()) { // text enter
if (!this.text.getText().isEmpty()) {
this.list.add(this.text.getText());
}
} else if (this.list == e.getSource()) { // list double-click
this.text.setText(this.list.getSelectedItem());
} else if (this.buttonClose == e.getSource()) { // buttonClose click
this.dispose();
}
}
}
///** Observer: ConcreteSubject からのイベント受け取り。 */
//public interface ActionListener extends EventListener {
// /** Observer.update() に相当。 */
// public void actionPerformed(ActionEvent e);
//}
///** ConcreteSubject: ボタン。 */
//public class Button(or TextField, List) extends Component {
// /** ConcreteSubject.needsAdvice() に相当。 */
// protected void processActionEvent(ActionEvent e) {
// ActionListener listener = actionListener;
// if (listener != null) {
// listener.actionPerformed(e); // ConcreteObserver.update() に相当
// }
// }
//}
}
