/[projects]/dao/DaoAdresseVedligehold/src/main/java/dk/daoas/adressevedligehold/afstandandenrute/AfstandAndenRuteTask.java
ViewVC logotype

Diff of /dao/DaoAdresseVedligehold/src/main/java/dk/daoas/adressevedligehold/afstandandenrute/AfstandAndenRuteTask.java

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

revision 2972 by torben, Tue Mar 8 09:41:53 2016 UTC revision 2976 by torben, Mon Mar 14 07:37:34 2016 UTC
# Line 7  import java.util.Map; Line 7  import java.util.Map;
7  import java.util.Queue;  import java.util.Queue;
8  import java.util.Set;  import java.util.Set;
9  import java.util.concurrent.CyclicBarrier;  import java.util.concurrent.CyclicBarrier;
10    import java.util.concurrent.ExecutorService;
11  import java.util.concurrent.Executors;  import java.util.concurrent.Executors;
12  import java.util.concurrent.ThreadFactory;  import java.util.concurrent.ThreadFactory;
 import java.util.concurrent.ThreadPoolExecutor;  
13  import java.util.concurrent.atomic.AtomicInteger;  import java.util.concurrent.atomic.AtomicInteger;
14    
15  import ags.utils.dataStructures.trees.thirdGenKD.KdTree;  import ags.utils.dataStructures.trees.thirdGenKD.KdTree;
# Line 43  public class AfstandAndenRuteTask extend Line 43  public class AfstandAndenRuteTask extend
43    
44    
45    
46          ThreadPoolExecutor threadPool;          ExecutorService threadPool;
47    
48          boolean isIncremental;          boolean isIncremental;
49    
# Line 122  public class AfstandAndenRuteTask extend Line 122  public class AfstandAndenRuteTask extend
122                  threadPool.shutdown(); //Calc is done now                  threadPool.shutdown(); //Calc is done now
123                                                    
124    
125                    ReloadHelper.triggerReload( "AfstandAndenRute/" + distributor );
126                    
127    
128                  long now = System.currentTimeMillis();                  long now = System.currentTimeMillis();
129                  long elapsed = now - start ;                  long elapsed = now - start ;
# Line 212  public class AfstandAndenRuteTask extend Line 214  public class AfstandAndenRuteTask extend
214                          db.saveBatch();                          db.saveBatch();
215                    
216                          if (test_mode == false && this.isAborted() == false) {                          if (test_mode == false && this.isAborted() == false) {
217                                  db.renameResultTables();                                  db.renameResultTables();                                
                                   
                                 ReloadHelper.triggerReload( "AfstandAndenRute/" + distributor );  
218                    
219                    
220                          } else {                          } else {
# Line 236  public class AfstandAndenRuteTask extend Line 236  public class AfstandAndenRuteTask extend
236          }          }
237    
238          private void setupThreadPool(int max_workers) {            private void setupThreadPool(int max_workers) {  
239                  threadPool = (ThreadPoolExecutor) Executors.newFixedThreadPool(max_workers, new WorkerThreadFactory() );                          threadPool = Executors.newFixedThreadPool(max_workers, new WorkerThreadFactory() );      
240          }          }
241    
242          static class WorkerThreadFactory implements ThreadFactory {                static class WorkerThreadFactory implements ThreadFactory {      
Legend:
Removed from v.2972  
changed lines
  Added in v.2976
  ViewVC Help
Powered by ViewVC 1.1.20