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

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

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

revision 2885 by torben, Sat Jan 30 19:20:43 2016 UTC revision 2891 by torben, Sun Jan 31 22:45:03 2016 UTC
# Line 34  public class LookupWorker implements Run Line 34  public class LookupWorker implements Run
34          Constants consts;          Constants consts;
35    
36          AtomicInteger antalFundne;          AtomicInteger antalFundne;
37            AtomicInteger antalBeregnet;
38    
39          int workerID;          int workerID;
40          boolean verbose;          boolean verbose;
# Line 48  public class LookupWorker implements Run Line 49  public class LookupWorker implements Run
49                          Queue<Address> ikkeDaekkede,                          Queue<Address> ikkeDaekkede,
50                          Map<Short, KdTree<Address>> hoTrees,                          Map<Short, KdTree<Address>> hoTrees,
51                          AtomicInteger antalFundne,                          AtomicInteger antalFundne,
52                            AtomicInteger antalBeregnet,
53                          Database db,                          Database db,
54                          boolean verbose,                          boolean verbose,
55                          Constants consts) {                          Constants consts) {
# Line 58  public class LookupWorker implements Run Line 60  public class LookupWorker implements Run
60                  this.ikkeDaekkede = ikkeDaekkede;                  this.ikkeDaekkede = ikkeDaekkede;
61                  this.hoTrees = hoTrees;                  this.hoTrees = hoTrees;
62                  this.antalFundne = antalFundne;                  this.antalFundne = antalFundne;
63                    this.antalBeregnet = antalBeregnet;
64                  this.db = db;                  this.db = db;
65                  this.verbose = verbose;                  this.verbose = verbose;
66                  this.consts = consts;                  this.consts = consts;
# Line 90  public class LookupWorker implements Run Line 93  public class LookupWorker implements Run
93                                  int size = res.size();                                  int size = res.size();
94                                  if (size > MAX_RESULTS ) {                                  if (size > MAX_RESULTS ) {
95                                          System.out.println("Returnerede mere end MAX_RESULTS> " + res.size() );                                          System.out.println("Returnerede mere end MAX_RESULTS> " + res.size() );
96                                          System.exit(0);                                          throw new Exception("Returnerede mere end MAX_RESULTS> " + res.size());
97                                  }                                  }
98    
99                                  ArrayList<Address> adrList = new ArrayList<Address>();                                  ArrayList<Address> adrList = new ArrayList<Address>();
# Line 142  public class LookupWorker implements Run Line 145  public class LookupWorker implements Run
145                                                  System.out.println("For stor afstand: " + qAddress + " > " + bedsteAfstand);                                                  System.out.println("For stor afstand: " + qAddress + " > " + bedsteAfstand);
146                                          }                                          }
147                                  }                                  }
148                                    
149                                    antalBeregnet.incrementAndGet();
150                          }                          }
151    
152                  } catch (Exception e) {                  } catch (Exception e) {
# Line 155  public class LookupWorker implements Run Line 159  public class LookupWorker implements Run
159                  try {                  try {
160                          logger.info( "Worker/" + workerID + " afventer barrier");                          logger.info( "Worker/" + workerID + " afventer barrier");
161                          barrier.await();                          barrier.await();
162                  } catch (BrokenBarrierException e) {                  } catch (Exception e) {
                         logger.log(Level.SEVERE, e.getMessage(), e);  
                         System.exit(-1);  
                 } catch(InterruptedException e) {  
163                          logger.log(Level.SEVERE, e.getMessage(), e);                          logger.log(Level.SEVERE, e.getMessage(), e);
164                  }                  }
165    
   
166                  System.out.println( "Worker/" + workerID + " stopping");                  System.out.println( "Worker/" + workerID + " stopping");
167          }          }
168    
Legend:
Removed from v.2885  
changed lines
  Added in v.2891
  ViewVC Help
Powered by ViewVC 1.1.20