/[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 2890 by torben, Sun Jan 31 21:56:30 2016 UTC revision 2891 by torben, Sun Jan 31 22:45:03 2016 UTC
# Line 35  public class AfstandAndenRuteTask extend Line 35  public class AfstandAndenRuteTask extend
35    
36    
37          String distributor;          String distributor;
38            int antalIkkeDaekkede = -1;
39            
40            AtomicInteger antalBeregnet = new AtomicInteger();
41    
42    
43    
# Line 79  public class AfstandAndenRuteTask extend Line 82  public class AfstandAndenRuteTask extend
82                  logger.info("Starting with MAX_WORKERS:" + max_workers);                          logger.info("Starting with MAX_WORKERS:" + max_workers);        
83                  setupThreadPool(max_workers);                  setupThreadPool(max_workers);
84    
85                  int antalIkkeDaekkede = -1;  
86    
87                  try (Connection conn = DBConnection.getConnection() ) {                  try (Connection conn = DBConnection.getConnection() ) {
88                          Database db = new Database(conn);                          Database db = new Database(conn);
# Line 144  public class AfstandAndenRuteTask extend Line 147  public class AfstandAndenRuteTask extend
147                                  CyclicBarrier barrier = new CyclicBarrier(max_workers + 1);                                  CyclicBarrier barrier = new CyclicBarrier(max_workers + 1);
148    
149                                  for (int i=0; i<max_workers; i++) {                                  for (int i=0; i<max_workers; i++) {
150                                          LookupWorker worker = new LookupWorker(i, this, barrier, ikkeDaekkede, hoTrees,antalFundne,db,verbose,consts);                                          LookupWorker worker = new LookupWorker(i, this, barrier, ikkeDaekkede, hoTrees,antalFundne,antalBeregnet,db,verbose,consts);
151                                          threadPool.submit( worker );                                          threadPool.submit( worker );
152                                  }                                  }
153    
# Line 236  public class AfstandAndenRuteTask extend Line 239  public class AfstandAndenRuteTask extend
239    
240          @Override          @Override
241          public String getDescription() {          public String getDescription() {
242                  return "Afstand anden rute";                  return "Afstand anden rute/" + distributor;
243          }          }
244    
245    
# Line 250  public class AfstandAndenRuteTask extend Line 253  public class AfstandAndenRuteTask extend
253    
254    
255          @Override          @Override
256          public short getPercentCompleted() {          public double getPercentCompleted() {
257                  // TODO Auto-generated method stub                  return (antalBeregnet.get() / ((float)antalIkkeDaekkede)) * 100.0;
                 return 0;  
258          }          }
259  }  }
Legend:
Removed from v.2890  
changed lines
  Added in v.2891
  ViewVC Help
Powered by ViewVC 1.1.20