/[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

revision 2725 by torben, Tue Sep 29 07:48:48 2015 UTC revision 2755 by torben, Tue Oct 20 10:36:06 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;
 import java.util.NoSuchElementException;  
6  import java.util.Queue;  import java.util.Queue;
7  import java.util.concurrent.BrokenBarrierException;  import java.util.concurrent.BrokenBarrierException;
8  import java.util.concurrent.CyclicBarrier;  import java.util.concurrent.CyclicBarrier;
# Line 11  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 {
20    
21          static final int MAX_RESULTS = 100;          static final int MAX_RESULTS = 99;
22    
23    
24    
# Line 36  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 69  public class LookupWorker implements Run Line 72  public class LookupWorker implements Run
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                                    int size = res.size();
78                                    if (size > MAX_RESULTS ) {
79                                          System.out.println("Returnerede mere end MAX_RESULTS> " + res.size() );                                          System.out.println("Returnerede mere end MAX_RESULTS> " + res.size() );
80                                          System.exit(0);                                          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  
94                          double bedsteAfstand = GeoPointHelper.beregnAfstand(qAdresse, bedsteAdr);                          if ( LookupMain.use_osrm == true) {
95                                                            //Hvis at den er inden for afstand, så prøver vi at lave findNærmste på vej distancen
96                          //Hvis at den er inden for afstand, så prøver vi at lave findNærmste på vej distancen                                  if (bedsteAfstand <= consts.getMaxDistance()) {
97                          if (bedsteAfstand <= consts.getMaxDistance()) {                                          //Adresse bedsteAdr2 = osrmHelper.getNearestViarouteHttp(qAdresse, res);
98                                  Adresse bedsteAdr2 = osrmHelper.getNearestViaTable(qAdresse, res);                                          //Adresse bedsteAdr2 = osrmHelper.getNearestViarouteJni(qAdresse, res);
99                                            Adresse bedsteAdr2 = osrmHelper.getNearestTableHttp(qAdresse, adrList);
100                                  if (bedsteAdr2 != null) {                                          //Adresse bedsteAdr2 = osrmHelper.getNearestTableJni(qAdresse, res);
101                                          bedsteAdr = bedsteAdr2;  
102                                          bedsteAfstand = GeoPointHelper.beregnAfstand(qAdresse, bedsteAdr);                                          if (bedsteAdr2 != null) {
103                                  } else {                                                  bedsteAdr = bedsteAdr2;
104                                          logger.info("NearestViaTable returned null for " + qAdresse);                                                  bedsteAfstand = GeoPointHelper.beregnAfstand(qAdresse, bedsteAdr);
105                                            } else {
106                                                    logger.info("OSRM returned null for " + qAdresse);
107                                            }
108                                  }                                  }
109                          }                          }
110                            
111    
112                                                    
113    
Legend:
Removed from v.2725  
changed lines
  Added in v.2755
  ViewVC Help
Powered by ViewVC 1.1.20