/[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 2975 by torben, Mon Mar 14 07:34:27 2016 UTC revision 2993 by torben, Tue Mar 29 19:49:38 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;
16  import dk.daoas.adressevedligehold.ReloadHelper;  import dk.daoas.adressevedligehold.ReloadTask;
17  import dk.daoas.adressevedligehold.ServiceConfig;  import dk.daoas.adressevedligehold.ServiceConfig;
18  import dk.daoas.adressevedligehold.beans.Address;  import dk.daoas.adressevedligehold.beans.Address;
19  import dk.daoas.adressevedligehold.db.DBConnection;  import dk.daoas.adressevedligehold.db.DBConnection;
# 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 );                  manager.submitTask( new ReloadTask("AfstandAndenRute/" + distributor) );
126                                    
127    
128                  long now = System.currentTimeMillis();                  long now = System.currentTimeMillis();
# 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.2975  
changed lines
  Added in v.2993
  ViewVC Help
Powered by ViewVC 1.1.20