/[projects]/dao/DaoAdresseVedligehold/src/main/java/dk/daoas/adressevedligehold/tasks/TaskManager.java
ViewVC logotype

Diff of /dao/DaoAdresseVedligehold/src/main/java/dk/daoas/adressevedligehold/tasks/TaskManager.java

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 2903 by torben, Wed Feb 3 18:45:33 2016 UTC revision 2928 by torben, Fri Feb 5 11:09:02 2016 UTC
# Line 8  import java.util.concurrent.ExecutorServ Line 8  import java.util.concurrent.ExecutorServ
8  import java.util.concurrent.Executors;  import java.util.concurrent.Executors;
9    
10  import dk.daoas.adressevedligehold.tasks.Task.TaskBean;  import dk.daoas.adressevedligehold.tasks.Task.TaskBean;
11    import dk.daoas.adressevedligehold.tasks.Task.TaskState;
12    
13  public class TaskManager {  public class TaskManager {
14                    
# Line 54  public class TaskManager { Line 55  public class TaskManager {
55                  executor.shutdownNow();                  executor.shutdownNow();
56          }          }
57                    
58            public synchronized void removeTask(Task removeTask) {
59                    if (removeTask.state == TaskState.STATE_QUEUED) {
60                            removeTask.doAbort();
61                    }
62                    
63                    if (removeTask.state == TaskState.STATE_ABORTED || removeTask.state == TaskState.STATE_DONE || removeTask.state == TaskState.STATE_QUEUED) {
64                            taskIdMap.remove( removeTask.getId() );
65                            tasks.remove(removeTask);
66                            return;
67                    }
68                    
69                    
70                    throw new RuntimeException("Cant remove task in current state:" + removeTask.state);
71                    
72            }
73            
74          public synchronized void submitTask(Task newTask) {          public synchronized void submitTask(Task newTask) {
75                  int id = getNextTaskid();                  int id = getNextTaskid();
76                  newTask.setId(id);                  newTask.setId(id);
Legend:
Removed from v.2903  
changed lines
  Added in v.2928
  ViewVC Help
Powered by ViewVC 1.1.20