Application: gvSIG desktop

/* gvSIG. Sistema de Informaci?n Geogr?fica de la Generalitat Valenciana

*

* Copyright (C) 2005 IVER T.I. and Generalitat Valenciana.

*

* This program is free software; you can redistribute it and/or

* modify it under the terms of the GNU General Public License

* as published by the Free Software Foundation; either version 2

* of the License, or (at your option) any later version.

*

* This program is distributed in the hope that it will be useful,

* but WITHOUT ANY WARRANTY; without even the implied warranty of

* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

* GNU General Public License for more details.

*

* You should have received a copy of the GNU General Public License

* along with this program; if not, write to the Free Software

* Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307,USA.

*/

package org.gvsig.gui.beans.incrementabletask;

import java.awt.event.ActionEvent;

import java.awt.event.ActionListener;

import java.awt.event.WindowAdapter;

import java.awt.event.WindowEvent;

import java.util.ArrayList;

import java.util.Iterator;

import org.gvsig.gui.beans.buttonspanel.ButtonsPanel;

import org.gvsig.gui.beans.progresspanel.ProgressPanel;

/**

 * <code>IncrementableTask</code>. Es un dialogo que contiene un ProgressPanel.

 * Se ejecuta bajo un Thread y va consultando a un objeto de tipo IIncrementable

 * para modificar sus valores.

 *

 * @version 29/03/2007

 * @author Borja S?nchez Zamorano (borja.sanchez@iver.es)

 */

public class IncrementableTask implements Runnable, ActionListener {

        IIncrementable iIncrementable;

        private volatile ProgressPanel progressPanel = getProgressPanel();

        private volatile Thread blinker;

        private boolean threadSuspended = false;

        private ArrayList actionCommandListeners = new ArrayList();

        private boolean bDoCallListeners = true;

        static private int eventId = Integer.MIN_VALUE;

        public IncrementableTask(IIncrementable incrementable) {

                iIncrementable = incrementable;

        }

        public void start() {

                blinker = new Thread(this);

                blinker.start();

        }

        public synchronized void stop() {

                blinker = null;

                notify();

        }        

        /**

         * Este thread va leyendo el porcentaje hasta que se completa el histograma.

         */

        public synchronized void run(){

                Thread thisThread = Thread.currentThread();

                while ((blinker == thisThread) && (iIncrementable.getPercent() < 100)) {

                        try {

                                Thread.sleep(100);

                                getProgressPanel().setLabel(iIncrementable.getLabel());

                                getProgressPanel().setPercent(iIncrementable.getPercent());

                                getProgressPanel().setTitle(iIncrementable.getTitle());

                                getProgressPanel().setLog(iIncrementable.getLog());

                                synchronized(this) {

                                        while (threadSuspended && blinker==thisThread)

                                                wait(500);

                                }

                        } catch (InterruptedException e) {

                        }

                }

                //Cerramos la ventana

                handleClose();

        }

        private void handleClose() {

                getProgressPanel().setVisible(false);

                getProgressPanel().hide();

                progressPanel = null;

                if (iIncrementable.getPercent() == 100)

                        callActionCommandListeners(IncrementableEvent.CLOSED);

                else

                        callActionCommandListeners(IncrementableEvent.CANCELED);

        }

        /**

         * Muestra la ventana de incremento con el porcentaje de la construcci?n del

         * histograma.

         */

        public void showWindow(){

                getProgressPanel().setTitle(iIncrementable.getTitle());

                getProgressPanel().showLog(false);

                getProgressPanel().show();

                this.start();

        }

        private ProgressPanel getProgressPanel() {

                if (progressPanel == null) {

                        progressPanel = new ProgressPanel();

                        progressPanel.getButtonsPanel().addActionListener(this);

                        progressPanel.addWindowListener( new WindowAdapter() {

        public void windowClosing(WindowEvent e)

        {

                blinker = null;

        }

      });

                }

                return progressPanel;

        }

        public void actionPerformed(ActionEvent e) {

                if (e.getActionCommand().compareTo(ButtonsPanel.BUTTON_CANCEL + "") == 0) {

            blinker = null;

                }

                if (e.getActionCommand().compareTo(ButtonsPanel.BUTTON_PAUSE + "") == 0) {

                        callActionCommandListeners(IncrementableEvent.SUSPENDED);

                        threadSuspended = true;

                }

                if (e.getActionCommand().compareTo(ButtonsPanel.BUTTON_RESTART + "") == 0) {

                        callActionCommandListeners(IncrementableEvent.RESUMED);

                        threadSuspended = false;

                }

        }

        private void callActionCommandListeners(int actions) {

                if (!bDoCallListeners)

                        return;

                Iterator acIterator = actionCommandListeners.iterator();

                while (acIterator.hasNext()) {

                        IncrementableListener listener = (IncrementableListener) acIterator.next();

                        switch (actions) {

                                case IncrementableEvent.CLOSED:

                                        listener.actionClosed(new IncrementableEvent(this));

                                        break;

                                case IncrementableEvent.RESUMED:

                                        listener.actionResumed(new IncrementableEvent(this));

                                        break;

                                case IncrementableEvent.SUSPENDED:

                                        listener.actionSuspended(new IncrementableEvent(this));

                                        break;

                                case IncrementableEvent.CANCELED:

                                        listener.actionCanceled(new IncrementableEvent(this));

                                        break;

                        }

                }

                eventId++;

        }

        public void addIncrementableListener(IncrementableListener listener) {

                if (!actionCommandListeners.contains(listener))

                        actionCommandListeners.add(listener);

        }

        public void removeIncrementableListener(IncrementableListener listener) {

                actionCommandListeners.remove(listener);

        }

}