adressevedligehold/tasks/Task.java

package dk.daoas.adressevedligehold.tasks;

import dk.daoas.adressevedligehold.util.TimingHelper;

public abstract class Task implements Runnable {
        
        public enum TaskState {
                STATE_QUEUED, STATE_RUNNING, STATE_DONE, STATE_ABORTED;
        }
        
        public static class TaskBean {
                public String description;
                public String detail;
                public String errorMessage;
                public double percentCompleted;
                public String state;
        }
        
        protected boolean abort = false;
        protected TaskState state = TaskState.STATE_QUEUED;
        protected TaskManager manager;
        private String errorMsg;
        
        public void setManager(TaskManager manager) {
                this.manager = manager;
        }
        
        @Override
        public final void run() {
                TimingHelper timing = new TimingHelper();
                System.out.println("Starting " + this.getDescription() );
                
                this.state = TaskState.STATE_RUNNING;
                manager.setCurrentTask(this);
                
                try {
                        taskRun();
                        this.state = TaskState.STATE_DONE;
                } catch (Exception e) {
                        this.errorMsg = e.getMessage();
                        e.printStackTrace();
                        this.state = TaskState.STATE_ABORTED;
                }
                
                manager.setCurrentTask(null);
                
                System.out.println("Done " + this.getDescription() + "   " + timing.getElapsed() + "ms");
        }
        
        
        public TaskState getState() {
                return this.state;
        }
        
        public void doAbort() {
                this.abort = true;
        }
        
        public TaskBean getTaskBean() {
                TaskBean bean = new TaskBean();
                
                bean.description = this.getDescription();
                bean.detail = this.getDetail();
                bean.percentCompleted = this.getPercentCompleted();
                bean.state = this.state.toString();
                bean.errorMessage = this.getErrorMessage();
                
                return bean;
        }
        
        public String getErrorMessage() {
                return this.errorMsg;
        }
        
        /**
         * @throws Exception
         * 
         * Implementing classes should not catch terminating exceptions but let it propagate to Task the Task::run()
         * method.
         */
        protected abstract void taskRun() throws Exception;
        
        public abstract String getDescription();
        public abstract String getDetail();
        public abstract short getPercentCompleted();
        
}
1	torben	2838	package dk.daoas.adressevedligehold.tasks;
2
3			import dk.daoas.adressevedligehold.util.TimingHelper;
4
5			public abstract class Task implements Runnable {
6
7			public enum TaskState {
8			STATE_QUEUED, STATE_RUNNING, STATE_DONE, STATE_ABORTED;
9			}
10
11			public static class TaskBean {
12			public String description;
13			public String detail;
14	torben	2844	public String errorMessage;
15	torben	2838	public double percentCompleted;
16			public String state;
17			}
18
19			protected boolean abort = false;
20			protected TaskState state = TaskState.STATE_QUEUED;
21			protected TaskManager manager;
22	torben	2844	private String errorMsg;
23	torben	2838
24			public void setManager(TaskManager manager) {
25			this.manager = manager;
26			}
27
28			@Override
29			public final void run() {
30			TimingHelper timing = new TimingHelper();
31			System.out.println("Starting " + this.getDescription() );
32
33			this.state = TaskState.STATE_RUNNING;
34			manager.setCurrentTask(this);
35
36			try {
37			taskRun();
38			this.state = TaskState.STATE_DONE;
39			} catch (Exception e) {
40	torben	2844	this.errorMsg = e.getMessage();
41			e.printStackTrace();
42	torben	2838	this.state = TaskState.STATE_ABORTED;
43			}
44
45			manager.setCurrentTask(null);
46
47			System.out.println("Done " + this.getDescription() + " " + timing.getElapsed() + "ms");
48			}
49
50
51			public TaskState getState() {
52			return this.state;
53			}
54
55			public void doAbort() {
56			this.abort = true;
57			}
58
59			public TaskBean getTaskBean() {
60			TaskBean bean = new TaskBean();
61
62			bean.description = this.getDescription();
63			bean.detail = this.getDetail();
64			bean.percentCompleted = this.getPercentCompleted();
65			bean.state = this.state.toString();
66	torben	2844	bean.errorMessage = this.getErrorMessage();
67	torben	2838
68			return bean;
69			}
70
71	torben	2844	public String getErrorMessage() {
72			return this.errorMsg;
73			}
74	torben	2838
75	torben	2844	/**
76			* @throws Exception
77			*
78			* Implementing classes should not catch terminating exceptions but let it propagate to Task the Task::run()
79			* method.
80			*/
81			protected abstract void taskRun() throws Exception;
82
83	torben	2838	public abstract String getDescription();
84			public abstract String getDetail();
85			public abstract short getPercentCompleted();
86
87			}