| gvSIG desktop 1

/* 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 org.gvsig.gui.beans.incrementabletask.IIncrementable;

import org.gvsig.gui.beans.incrementabletask.IncrementableEvent;

import org.gvsig.gui.beans.incrementabletask.IncrementableListener;

import org.gvsig.gui.beans.incrementabletask.IncrementableTask;

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

public class TestIncrementableTask {

        class ClassProcess implements Runnable, IIncrementable, IncrementableListener {

                int i = 0;

                long j = 0;

                LogControl log = new LogControl();

                IncrementableTask incrementableTask = null;

                private volatile Thread blinker;

                private boolean ended = false;

                private boolean threadSuspended = false;

                public ClassProcess() {

                }

                public void start() {

                        blinker = new Thread(this);

                        blinker.start();

                }

                public synchronized void stop() {

                        ended = true;

                        blinker = null;

                        notify();

                }        

                public boolean isAlive() {

                        return blinker.isAlive(); 

                }

                public synchronized void run(){

                        for (j=0; j<=65535; j++) {

                                if (ended) break;

                                for (long i=0; i<=65535; i++);

                                log.replaceLastLine(j + "");

                                if ((j%1000)==0) {

                                        log.addLine(j + "");

                                }

                                synchronized(this) {

                                        while (threadSuspended && !ended)

                                                try {

                                                        wait(500);

                                                } catch (InterruptedException e) {

                                                        e.printStackTrace();

                                                }

                                }

                        }

                        while (incrementableTask.isAlive());

                        incrementableTask.Hide();

                        incrementableTask = null;

                }

                public String getLabel() {

                        return "Etiqueta " + j;

                }

                public String getLog() {

                        return log.getText();

                }

                public int getPercent() {

                        return (int) ((j*100)/65535);

                }

                public String getTitle() {

                        return "TestIncrementTask";

                }

                public void setIncrementableTask(IncrementableTask value) {

                        incrementableTask = value;

                }

                public void actionCanceled(IncrementableEvent e) {

                        ended = true;

                }

                public void actionResumed(IncrementableEvent e) {

                        threadSuspended = false;

                }

                public void actionSuspended(IncrementableEvent e) {

                        threadSuspended = true;

                }

        }

  ClassProcess classProcess = null;

        public TestIncrementableTask() {

                super();

                initialize();

        }

        private void initialize() {

                classProcess = new ClassProcess();

                IncrementableTask incrementableTask = new IncrementableTask(classProcess);

                classProcess.setIncrementableTask(incrementableTask);

                incrementableTask.showWindow();

                incrementableTask.addIncrementableListener(classProcess);

                incrementableTask.start();

                classProcess.start();

                while (classProcess.isAlive()) {

                        try {

                                Thread.sleep(500);

                        } catch (InterruptedException e) {

                                e.printStackTrace();

                        }

                }

                classProcess.stop();

                classProcess = null;

                incrementableTask = null;

        }

        public static void main(String[] args) {

                new TestIncrementableTask();

        }

}