Application: gvSIG desktop » Library: org.gvsig.tools

 *

    private static final int MAXTASKS_TO_AUTOREMOVE = 15;

    private static long codeCounter = 1;

    private Map tasksStatus = null;

    private ObservableHelper observers = null;

    public DefaultTaskStatusManager() {

        this.tasksStatus = new LinkedHashMap();

        this.observers = new ObservableHelper();

    }

    @Override

    synchronized public void add(TaskStatus taskStatus) {

        this.tasksStatus.put(taskStatus.getCode(), taskStatus);

        this.update(taskStatus);

    }

    @Override

    synchronized public TaskStatus get(String code) {

        return (TaskStatus) (this.tasksStatus.get(code));

    }

    @Override

    synchronized public void remove(String code) {

        this.tasksStatus.remove(code);

        this.update((TaskStatus) this.tasksStatus.get(code));

    }

    @Override

    synchronized public void remove(TaskStatus taskStatus) {

        this.tasksStatus.remove(taskStatus.getCode());

        this.update(null);

    }

    @Override

    public String getNewCode() {

        return Long.toBinaryString(codeCounter++);

    }

    @Override

    synchronized public Map getAll() {

        return Collections.unmodifiableMap(this.tasksStatus);

    }

    @Override

    synchronized public boolean isEmpty() {

        return this.tasksStatus.isEmpty();

    }

    @Override

    synchronized public void addObserver(Observer o) {

        this.observers.addObserver(o);

    }

    @Override

    synchronized public void deleteObserver(Observer o) {

        this.observers.deleteObserver(o);

    }

    @Override

    synchronized public void deleteObservers() {

        this.observers.deleteObservers();

    }

    @Override

    synchronized public void update(TaskStatus taskstatus) {

        if (taskstatus != null

                && this.tasksStatus.get(taskstatus.getCode()) == null) {

            // This TaskStatus not is registered in this manager.

            return;

        }

        this.observers.notifyObservers(this, taskstatus);

        if (taskstatus != null) {

            if (!taskstatus.isRunning()) {

                if (taskstatus instanceof SimpleTaskStatus) {

                    if (((SimpleTaskStatus) taskstatus).getAutoRemove()) {

                        if (this.tasksStatus.size() > MAXTASKS_TO_AUTOREMOVE) {

                            ((SimpleTaskStatus) taskstatus).remove();

                        }

                    }

                }

            }

        }

    }

    @Override

    public SimpleTaskStatus creteDefaultSimpleTaskStatus(String tittle) {

    @Override

    }

    @Override

    synchronized public TaskStatus getRunningTaskStatusMostRecent() {

        TaskStatus mostRecent = null;

        Iterator taskStatusIterator = this.tasksStatus.values().iterator();

        while (taskStatusIterator.hasNext()) {

            TaskStatus current = (TaskStatus) taskStatusIterator.next();

            if (current.isRunning()) {

                if (mostRecent == null || current.getLastModification().compareTo(mostRecent.getLastModification()) > 0) {

                    mostRecent = current;

                }

            }

        }

        return mostRecent;

    }