Application: gvSIG desktop

/*

 * To change this license header, choose License Headers in Project Properties.

 * To change this template file, choose Tools | Templates

 * and open the template in the editor.

 */

package org.gvsig.xml2db.swing.impl;

import java.awt.Color;

import javax.swing.SwingUtilities;

import org.apache.commons.lang3.mutable.MutableBoolean;

import org.gvsig.tools.ToolsLocator;

import org.gvsig.tools.exception.BaseException;

import org.gvsig.tools.swing.api.task.TaskStatusController;

import org.gvsig.tools.task.SimpleTaskStatus;

/**

 *

 * @author jjdelcerro

 */

public abstract class Task implements Runnable {

    private final String title;

    private final String name;

    private final TaskStatusController taskStatusController;

    private final MutableBoolean processing;

    private final Runnable updateStateComponents;

    private SimpleTaskStatus taskStatus;

    public static final Task FAKE_TASK = new Task("None", "None") {

            @Override

            protected void task(SimpleTaskStatus taskStatus) throws Throwable {

            }

            @Override

            public void start() {

            }

    };

    public static final Task get(Task task) {

        if( task==null ) {

            return FAKE_TASK;

        }

        return task;

    }

    public Task(String name, String title, MutableBoolean processing, Runnable updateStateComponents, TaskStatusController taskStatusController) {

        this.name = name;

        this.title = title;

        this.processing = processing;

        this.updateStateComponents = updateStateComponents;

        this.taskStatusController = taskStatusController;

        this.taskStatus = null;

    }

    public Task(String name, String title, Runnable updateStateComponents, TaskStatusController taskStatusController) {

        this(name, title, new MutableBoolean(false), updateStateComponents, taskStatusController);

    }

    public Task(String name, String title, MutableBoolean processing, Runnable updateStateComponents) {

        this(name, title, processing, updateStateComponents, null);

    }

    public Task(String name, String title, MutableBoolean processing) {

        this(name, title, processing, null, null);

    }

    public Task(String name, String title) {

        this(name, title, new MutableBoolean(false), null, null);

    }

    private void updateStateComponents() {

        if (this.updateStateComponents != null) {

            SwingUtilities.invokeLater(updateStateComponents);

        }

    }

    @Override

    public final void run() {

        this.processing.setTrue();

        this.taskStatus = ToolsLocator.getTaskStatusManager().createDefaultSimpleTaskStatus(this.title);

        try {

            updateStateComponents();

            if (this.taskStatusController != null) {

                this.taskStatusController.bind(taskStatus);

                this.taskStatusController.setVisible(processing.booleanValue());

            }

            this.taskStatus.add();

            this.task(this.taskStatus);

            this.taskStatus.terminate();

        } catch (Throwable ex) {

            this.taskStatus.abort();

//            String s = Xml2dbSwingCommons.getHTMLColorTag(Color.RED.darker(), BaseException.getMessageStack(ex, 0));            

            String s = BaseException.getMessageStack(ex, 0);            

            this.taskStatus.message(s);

        } finally {

            this.processing.setFalse();

            if (!(this.taskStatus.isAborted() || this.taskStatus.isCancelled())) {

                this.taskStatus.remove();

                this.taskStatusController.setVisible(processing.booleanValue());

            }

            updateStateComponents();

            this.postTask();

        }

    }

    public void start() {

        Thread th = new Thread(this, this.name);

        th.start();

    }

    public boolean isProcessing() {

        return this.processing.booleanValue();

    }

    public boolean needToShowTheStatus() {

        if( taskStatus == null ) {

            return false;

        }

        if( this.processing.isTrue() ) {

            return true;

        }

        return this.taskStatus.isAborted() || this.taskStatus.isCancelled();

    }

    protected abstract void task(SimpleTaskStatus taskStatus) throws Throwable;

    protected void postTask() {

    }

}