/[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 2903 by torben, Wed Feb 3 18:45:33 2016 UTC revision 2948 by torben, Sat Feb 13 15:56:00 2016 UTC
# Line 29  public class LookupWorker implements Run Line 29  public class LookupWorker implements Run
29          CyclicBarrier barrier;          CyclicBarrier barrier;
30          Queue<Address> ikkeDaekkede;          Queue<Address> ikkeDaekkede;
31          Map<Short, KdTree<Address>> hoTrees;          Map<Short, KdTree<Address>> hoTrees;
32          Database db;          DatabaseRouteDistance db;
33          Constants consts;          Constants consts;
34    
35          AtomicInteger antalFundne;          AtomicInteger antalFundne;
# Line 49  public class LookupWorker implements Run Line 49  public class LookupWorker implements Run
49                          Map<Short, KdTree<Address>> hoTrees,                          Map<Short, KdTree<Address>> hoTrees,
50                          AtomicInteger antalFundne,                          AtomicInteger antalFundne,
51                          AtomicInteger antalBeregnet,                          AtomicInteger antalBeregnet,
52                          Database db,                          DatabaseRouteDistance db,
53                          boolean verbose,                          boolean verbose,
54                          Constants consts) {                          Constants consts) {
55    
# Line 69  public class LookupWorker implements Run Line 69  public class LookupWorker implements Run
69    
70          @Override          @Override
71          public void run() {          public void run() {
72                  System.out.println( "Worker/" + workerID + " starting");                  logger.info( "Worker/" + workerID + " starting");
73    
74                  ServiceConfig conf = ServiceConfig.getInstance();                  ServiceConfig conf = ServiceConfig.getInstance();
75    
# Line 77  public class LookupWorker implements Run Line 77  public class LookupWorker implements Run
77                          while ( ! ikkeDaekkede.isEmpty() ) {                          while ( ! ikkeDaekkede.isEmpty() ) {
78    
79                                  if (task.isAborted()) {                                  if (task.isAborted()) {
80                                          System.out.println( "Worker/" + workerID + " aborting");                                          logger.info( "Worker/" + workerID + " aborting");
81                                          break;                                          break;
82                                  }                                  }
83    
# Line 88  public class LookupWorker implements Run Line 88  public class LookupWorker implements Run
88                                  KdTree<Address> addressTree = hoTrees.get(ho);                                  KdTree<Address> addressTree = hoTrees.get(ho);
89    
90                                  MaxHeap<Address> res = addressTree.findNearestNeighbors(qAddress.xyz, MAX_RESULTS, dist);                                  MaxHeap<Address> res = addressTree.findNearestNeighbors(qAddress.xyz, MAX_RESULTS, dist);
91                                  //Collection<Address> res = addressTree.nearestNeighbourSearch(MAX_RESULTS, qAddress);  
92                                  int size = res.size();                                  int size = res.size();
93                                  if (size > MAX_RESULTS ) {                                  if (size > MAX_RESULTS ) {
94                                          System.out.println("Returnerede mere end MAX_RESULTS> " + res.size() );                                          logger.info("Returnerede mere end MAX_RESULTS> " + res.size() );
95                                          throw new Exception("Returnerede mere end MAX_RESULTS> " + res.size());                                          throw new Exception("Returnerede mere end MAX_RESULTS> " + res.size());
96                                  }                                  }
97    
# Line 141  public class LookupWorker implements Run Line 141  public class LookupWorker implements Run
141                                          }                                          }
142                                  } else {                                  } else {
143                                          if (verbose == true) {                                          if (verbose == true) {
144                                                  System.out.println("For stor afstand: " + qAddress + " > " + bedsteAfstand);                                                  logger.fine("For stor afstand: " + qAddress + " > " + bedsteAfstand);
145                                          }                                          }
146                                  }                                  }
147                                                                    
# Line 156  public class LookupWorker implements Run Line 156  public class LookupWorker implements Run
156    
157                                    
158    
159                  System.out.println( "Worker/" + workerID + " stopping");                  logger.info( "Worker/" + workerID + " stopping");
160          }          }
161                    
162                    
Legend:
Removed from v.2903  
changed lines
  Added in v.2948
  ViewVC Help
Powered by ViewVC 1.1.20