/[projects]/dao/FuldDaekningWorker/src/main/java/dk/daoas/fulddaekning/LookupWorker.java
ViewVC logotype

Diff of /dao/FuldDaekningWorker/src/main/java/dk/daoas/fulddaekning/LookupWorker.java

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

dao/FuldDaekningWorker/src/dk/daoas/fulddaekning/LookupWorker.java revision 2718 by torben, Mon Sep 28 11:09:33 2015 UTC dao/FuldDaekningWorker/src/main/java/dk/daoas/fulddaekning/LookupWorker.java revision 2745 by torben, Wed Oct 7 19:35:24 2015 UTC
# Line 1  Line 1 
1  package dk.daoas.fulddaekning;  package dk.daoas.fulddaekning;
2    
3  import java.sql.SQLException;  import java.sql.SQLException;
4  import java.util.Collection;  import java.util.ArrayList;
5  import java.util.Map;  import java.util.Map;
6  import java.util.Queue;  import java.util.Queue;
7  import java.util.concurrent.BrokenBarrierException;  import java.util.concurrent.BrokenBarrierException;
# Line 10  import java.util.concurrent.atomic.Atomi Line 10  import java.util.concurrent.atomic.Atomi
10  import java.util.logging.Level;  import java.util.logging.Level;
11  import java.util.logging.Logger;  import java.util.logging.Logger;
12    
13  import com.jwetherell.algorithms.data_structures.KdTree;  import ags.utils.dataStructures.MaxHeap;
14    import ags.utils.dataStructures.trees.thirdGenKD.DistanceFunction;
15    import ags.utils.dataStructures.trees.thirdGenKD.KdTree;
16    import ags.utils.dataStructures.trees.thirdGenKD.SquareEuclideanDistanceFunction;
17  import dk.daoas.fulddaekning.osrm.OSRMHelper;  import dk.daoas.fulddaekning.osrm.OSRMHelper;
18    
19  public class LookupWorker implements Runnable {  public class LookupWorker implements Runnable {
# Line 35  public class LookupWorker implements Run Line 37  public class LookupWorker implements Run
37          int workerID;          int workerID;
38          boolean verbose;          boolean verbose;
39                    
40            DistanceFunction dist = new SquareEuclideanDistanceFunction();
41            
42          public LookupWorker(int workerID,          public LookupWorker(int workerID,
43                                  CyclicBarrier barrier,                                  CyclicBarrier barrier,
44                                  Queue<Adresse> ikkeDaekkede,                                  Queue<Adresse> ikkeDaekkede,
# Line 60  public class LookupWorker implements Run Line 64  public class LookupWorker implements Run
64          public void run() {          public void run() {
65                  System.out.println( "Worker/" + workerID + " starting");                  System.out.println( "Worker/" + workerID + " starting");
66    
67                  while ( ! ikkeDaekkede.isEmpty() ) {                  try {
68                            while ( ! ikkeDaekkede.isEmpty() ) {
69                                                    
70                          Adresse qAdresse = ikkeDaekkede.remove();                                  Adresse qAdresse = ikkeDaekkede.remove();
71    
72                          short ho = qAdresse.ho;                                  short ho = qAdresse.ho;
73                          KdTree<Adresse> addressTree = hoTrees.get(ho);                                  KdTree<Adresse> addressTree = hoTrees.get(ho);
74    
75                          Collection<Adresse> res = addressTree.nearestNeighbourSearch(MAX_RESULTS, qAdresse);                                  MaxHeap<Adresse> res = addressTree.findNearestNeighbors(qAdresse.xyz, MAX_RESULTS, dist);
76                          if (res.size() > MAX_RESULTS ) {                                  //Collection<Adresse> res = addressTree.nearestNeighbourSearch(MAX_RESULTS, qAdresse);
77                                  System.out.println("Returnerede mere end MAX_RESULTS> " + res.size() );                                  int size = res.size();
78                                  System.exit(0);                                  if (size > MAX_RESULTS ) {
79                          }                                          System.out.println("Returnerede mere end MAX_RESULTS> " + res.size() );
80                                            System.exit(0);
81                                    }
82                                    
83                                    ArrayList<Adresse> adrList = new ArrayList<Adresse>();
84    
85                                    for (int i=0; i<size; i++) {
86                                            Adresse a = res.getMax();
87                                            adrList.add(a);
88                                            res.removeMax();
89                                    }
90                                    Adresse bedsteAdr = adrList.get(size-1); //da det er en max-heap er det elementet med størst distance der er først og dermed den sidste der er tættest
91                                    double bedsteAfstand = GeoPointHelper.beregnAfstand(qAdresse, bedsteAdr);
92    
93                          Adresse bedsteAdr = res.iterator().next(); //Tag første element  /*                      
                         double bedsteAfstand = GeoPointHelper.beregnAfstand(qAdresse, bedsteAdr);  
                           
94                          //Hvis at den er inden for afstand, så prøver vi at lave findNærmste på vej distancen                          //Hvis at den er inden for afstand, så prøver vi at lave findNærmste på vej distancen
95                          if (bedsteAfstand <= consts.getMaxDistance()) {                          if (bedsteAfstand <= consts.getMaxDistance()) {
96                                  bedsteAdr = osrmHelper.getNearestViaTable(qAdresse, res);                                  //Adresse bedsteAdr2 = osrmHelper.getNearestViarouteHttp(qAdresse, res);
97                                  bedsteAfstand = GeoPointHelper.beregnAfstand(qAdresse, bedsteAdr);                                  //Adresse bedsteAdr2 = osrmHelper.getNearestViarouteJni(qAdresse, res);
98                                    Adresse bedsteAdr2 = osrmHelper.getNearestTableHttp(qAdresse, res);
99                                    //Adresse bedsteAdr2 = osrmHelper.getNearestTableJni(qAdresse, res);
100    
101                                    if (bedsteAdr2 != null) {
102                                            bedsteAdr = bedsteAdr2;
103                                            bedsteAfstand = GeoPointHelper.beregnAfstand(qAdresse, bedsteAdr);
104                                    } else {
105                                            logger.info("NearestViaTable returned null for " + qAdresse);
106                                    }
107                          }                          }
108                            */              
109    
110                                                    
111    
# Line 108  public class LookupWorker implements Run Line 131  public class LookupWorker implements Run
131                                  }                                  }
132                          }                          }
133    
134                            }
135    
136                    } catch (Exception e) {
137                            logger.log( Level.SEVERE, "Worker/" + workerID, e);
138                  }                  }
139    
140    
141    
142                  try {                  try {
143                            logger.info( "Worker/" + workerID + " afventer barrier");
144                          barrier.await();                          barrier.await();
145                  } catch (BrokenBarrierException e) {                  } catch (BrokenBarrierException e) {
146                          logger.log(Level.SEVERE, e.getMessage(), e);                          logger.log(Level.SEVERE, e.getMessage(), e);
147                          System.exit(-1);                          System.exit(-1);
148                  } catch(InterruptedException e) {                  } catch(InterruptedException e) {
149                          //Do nothing                          logger.log(Level.SEVERE, e.getMessage(), e);
150                  }                  }
151    
152    
Legend:
Removed from v.2718  
changed lines
  Added in v.2745
  ViewVC Help
Powered by ViewVC 1.1.20