| gvSIG desktop 1

package org.gvsig.data;

import java.lang.ref.Reference;

import java.lang.ref.WeakReference;

import java.util.ArrayList;

import java.util.Iterator;

import java.util.Vector;

public class ComplexObservable implements IObservable{

        private boolean propageNotifications=true;

        private boolean inComplex=false;

        private ComplexNotification complexNotification= null;

        private boolean changed = false;

    private Vector obs;

    /** Construct an Observable with zero Observers. */

    public ComplexObservable() {

                obs = new Vector();

                this.inComplex=false;

    }

    /**

     * 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(IObserver o) {

        if (o == null)

            throw new NullPointerException();

                if (!contains(o)) {

                    obs.addElement(o);

                }

    }

    public synchronized void addObserver(Reference ref) {

        if (ref == null || ref.get() == null)

            throw new NullPointerException();

        IObserver o = (IObserver)ref.get();

                if (!contains(o)) {

                    obs.addElement(ref);

                }

    }

    private boolean contains(IObserver o){

            if (obs.contains(o)){

                    return true;

            }

        Iterator iter = obs.iterator();

        Object obj;

        Reference ref1;

        while (iter.hasNext()){

                obj = iter.next();

                if (obj instanceof Reference){

                        ref1 = (Reference)obj;

                        if (o.equals(ref1.get())){

                                return true;

                        }

                }

        }

        return false;

    }

    /**

     * 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(IObserver o) {

        if (!obs.removeElement(o)){

                this.deleteObserverReferenced(o);

        }

    }

    private void deleteObserverReferenced(IObserver o){

        Iterator iter = obs.iterator();

        Object obj;

        ArrayList toRemove = new ArrayList();

        Reference ref1;

        while (iter.hasNext()){

                obj = iter.next();

                if (obj instanceof Reference){

                        ref1 = (Reference)obj;

                        if (ref1.get() == null || o.equals(ref1.get())){

                                toRemove.add(obj);

                        }

                }

        }

        iter = toRemove.iterator();

        while (iter.hasNext()){

                obs.remove(iter.next());

        }

    }

    public synchronized void deleteObserver(Reference ref) {

            IObserver o = (IObserver)ref.get();

        obs.removeElement(ref);

        if (o == null)

                return;

        deleteObserverReferenced(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() {

            throw new UnsupportedOperationException("Notify requires an notification Object");

    }

    /**

     * 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) {

            if (!this.inComplex){

                        this.setChanged();

                        notify(arg);

                }else{

                        complexNotification.addNotification(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() {

            clearDeadReferences();

            return obs.size();

    }

        public void enableNotifications(){

                clearDeadReferences();

                this.propageNotifications =true;

        }

        public void diableNotifications(){

                this.propageNotifications =false;

        }

        public boolean isEnabledNotifications(){

                return this.propageNotifications;

        }

        public boolean inComplex(){

                return this.inComplex;

        }

        public void beginComplexNotification(){

                clearDeadReferences();

                this.clearChanged();

                inComplex=true;

                complexNotification=new ComplexNotification();

        }

        public void endComplexNotification(){

                inComplex=false;

                this.setChanged();

                Iterator iter=complexNotification.getIterator();

                while(iter.hasNext()){

                        notify(iter.next());

                }

        }

        protected synchronized void clearDeadReferences(){

        Iterator iter = obs.iterator();

        Object obj;

        ArrayList toRemove = new ArrayList();

        Reference ref1;

        while (iter.hasNext()){

                obj = iter.next();

                if (obj instanceof Reference){

                        ref1 = (Reference)obj;

                        if (ref1.get() == null){

                                toRemove.add(obj);

                        }

                }

        }

        iter = toRemove.iterator();

        while (iter.hasNext()){

                obs.remove(iter.next());

        }

        }

        private void notify(Object object) {

                /*

         * 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();

        }

                Object obj;

                IObserver observer;

                ArrayList toRemove = new ArrayList();

        for (int i = arrLocal.length-1; i>=0; i--){

                obj = arrLocal[i];

                if (obj instanceof Reference){

                        observer = (IObserver)((Reference)obj).get();

                        if (observer == null){

                                toRemove.add(obj);

                                continue;

                        }

                } else {

                        observer = (IObserver)obj;

                }

            observer.update(this, object);

        }

        Iterator iter = toRemove.iterator();

        while (iter.hasNext()){

                obs.remove(iter.next());

        }

        }

}