读书人

观察者模式(Observer)-jdk

发布时间: 2012-10-31 14:37:32 作者: rapoo

观察者模式(Observer)---jdk

一,在平常的积累中观察者模式被使用最多的应该就是AWT/Swing里面了了,addActionListener(listener);....

jdk中提供的Observer接口,实现这个接口,在update中实现相应的操作,在监听器被触发时将会执行....(监听者)

?

package java.util;public class Observable {    private boolean changed = false;    private Vector obs;       /** Construct an Observable with zero Observers. */    public Observable() {obs = new Vector();    }    /**     * Adds an observer to the set of observers for this object, provided      * that it is not the same as some observer already in the set.      * The order in which notifications will be delivered to multiple      * observers is not specified. See the class comment.     *     * @param   o   an observer to be added.     * @throws NullPointerException   if the parameter o is null.     */    public synchronized void addObserver(Observer o) {        if (o == null)            throw new NullPointerException();if (!obs.contains(o)) {    obs.addElement(o);}    }    /**     * Deletes an observer from the set of observers of this object.      * Passing <CODE>null</CODE> to this method will have no effect.     * @param   o   the observer to be deleted.     */    public synchronized void deleteObserver(Observer o) {        obs.removeElement(o);    }    /**     * If this object has changed, as indicated by the      * <code>hasChanged</code> method, then notify all of its observers      * and then call the <code>clearChanged</code> method to      * indicate that this object has no longer changed.      * <p>     * Each observer has its <code>update</code> method called with two     * arguments: this observable object and <code>null</code>. In other      * words, this method is equivalent to:     * <blockquote><tt>     * notifyObservers(null)</tt></blockquote>     *     * @see     java.util.Observable#clearChanged()     * @see     java.util.Observable#hasChanged()     * @see     java.util.Observer#update(java.util.Observable, java.lang.Object)     */    public void notifyObservers() {notifyObservers(null);    }    /**     * If this object has changed, as indicated by the      * <code>hasChanged</code> method, then notify all of its observers      * and then call the <code>clearChanged</code> method to indicate      * that this object has no longer changed.      * <p>     * Each observer has its <code>update</code> method called with two     * arguments: this observable object and the <code>arg</code> argument.     *     * @param   arg   any object.     * @see     java.util.Observable#clearChanged()     * @see     java.util.Observable#hasChanged()     * @see     java.util.Observer#update(java.util.Observable, java.lang.Object)     */    public void notifyObservers(Object arg) {/*         * a temporary array buffer, used as a snapshot of the state of         * current Observers.         */        Object[] arrLocal;synchronized (this) {    /* We don't want the Observer doing callbacks into     * arbitrary code while holding its own Monitor.     * The code where we extract each Observable from      * the Vector and store the state of the Observer     * needs synchronization, but notifying observers     * does not (should not).  The worst result of any      * potential race-condition here is that:     * 1) a newly-added Observer will miss a     *   notification in progress     * 2) a recently unregistered Observer will be     *   wrongly notified when it doesn't care     */    if (!changed)                return;            arrLocal = obs.toArray();            clearChanged();        }        for (int i = arrLocal.length-1; i>=0; i--)            ((Observer)arrLocal[i]).update(this, arg);    }    /**     * Clears the observer list so that this object no longer has any observers.     */    public synchronized void deleteObservers() {obs.removeAllElements();    }    /**     * Marks this <tt>Observable</tt> object as having been changed; the      * <tt>hasChanged</tt> method will now return <tt>true</tt>.     */    protected synchronized void setChanged() {changed = true;    }    /**     * Indicates that this object has no longer changed, or that it has      * already notified all of its observers of its most recent change,      * so that the <tt>hasChanged</tt> method will now return <tt>false</tt>.      * This method is called automatically by the      * <code>notifyObservers</code> methods.      *     * @see     java.util.Observable#notifyObservers()     * @see     java.util.Observable#notifyObservers(java.lang.Object)     */    protected synchronized void clearChanged() {changed = false;    }    /**     * Tests if this object has changed.      *     * @return  <code>true</code> if and only if the <code>setChanged</code>      *          method has been called more recently than the      *          <code>clearChanged</code> method on this object;      *          <code>false</code> otherwise.     * @see     java.util.Observable#clearChanged()     * @see     java.util.Observable#setChanged()     */    public synchronized boolean hasChanged() {return changed;    }    /**     * Returns the number of observers of this <tt>Observable</tt> object.     *     * @return  the number of observers of this object.     */    public synchronized int countObservers() {return obs.size();    }}
?

?

每一个observeable添加监控自己的observer,当自己改变时,通知这些server。。。

?

读书人网 >软件架构设计

热点推荐