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

Diff of /dao/FuldDaekningWorker/src/dk/daoas/fulddaekning/LookupMain.java

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

revision 2244 by torben, Wed Dec 10 10:06:32 2014 UTC revision 2263 by torben, Tue Feb 10 16:27:15 2015 UTC
# Line 6  import java.util.List; Line 6  import java.util.List;
6  import java.util.logging.FileHandler;  import java.util.logging.FileHandler;
7  import java.util.logging.Logger;  import java.util.logging.Logger;
8  import java.util.logging.SimpleFormatter;  import java.util.logging.SimpleFormatter;
9    import java.util.concurrent.*;
10    
11  public class LookupMain {  public class LookupMain {
12    
# Line 29  public class LookupMain { Line 30  public class LookupMain {
30          static Statistik stoersteDataset = new Statistik();          static Statistik stoersteDataset = new Statistik();
31                    
32          static Adresse[] alleDaekkedeAdresser;          static Adresse[] alleDaekkedeAdresser;
33    
34            static ThreadPoolExecutor threadPool;
35    
36            private static void setupThreadPool() {
37                    threadPool = (ThreadPoolExecutor) Executors.newFixedThreadPool(max_workers, new WorkerThreadFactory() );
38            }
39                    
40                    
41          public static void main(String[] args) throws Exception {          public static void main(String[] args) throws Exception {
# Line 61  public class LookupMain { Line 68  public class LookupMain {
68                                                    
69                  }                  }
70                  logger.info("Starting with MAX_WORKERS:" + max_workers);                  logger.info("Starting with MAX_WORKERS:" + max_workers);
71                    setupThreadPool();
72                                    
73                                    
74                  verbose = Boolean.parseBoolean( conf.getSafeProperty("VERBOSE") );                  verbose = Boolean.parseBoolean( conf.getSafeProperty("VERBOSE") );
# Line 77  public class LookupMain { Line 85  public class LookupMain {
85                  Constants consts = Constants.getInstance();                  Constants consts = Constants.getInstance();
86                                    
87                  Database db = new Database(conf);                  Database db = new Database(conf);
                   
                   
88    
89                                    
90                  boolean testRun= false;                  boolean testRun= false;
# Line 98  public class LookupMain { Line 104  public class LookupMain {
104                                  bbox.validateBbox();                                  bbox.validateBbox();
105                          }                          }
106                                                    
107                          if (consts.doExtendedLookup()) {  
108                                  logger.info("Henter alle daekkede adresser");                          logger.info("Henter alle daekkede adresser");
109                                  alleDaekkedeAdresser = db.hentAlleDaekkedeAdresser();                          alleDaekkedeAdresser = db.hentAlleDaekkedeAdresser();
110                                  logger.info( "AlleDaekkedeAdresser.length=" + alleDaekkedeAdresser.length);                          logger.info( "AlleDaekkedeAdresser.length=" + alleDaekkedeAdresser.length);                    
                         }  
                           
111                                                    
112                          //pre-check er ok - reset tmp tabel og start søgningen                          //pre-check er ok - reset tmp tabel og start søgningen
113                          db.resetResultTable();                          db.resetResultTable();
114                                                    
115                          for(String postnr : postnumre) {                          for(String postnr : postnumre) {
116                                  Lookup lookup = new Lookup(postnr, db);                                  Lookup lookup = new Lookup(postnr, db, threadPool);
117                                  lookup.doLookup();                                                        lookup.doLookup();                      
118                          }                          }
119                                                    
# Line 130  public class LookupMain { Line 134  public class LookupMain {
134                                  logger.info( "AlleDaekkedeAdresser.length=" + alleDaekkedeAdresser.length);                                  logger.info( "AlleDaekkedeAdresser.length=" + alleDaekkedeAdresser.length);
135                          }                          }
136                                                    
137                          Lookup lookup = new Lookup("458x", db);                          Lookup lookup = new Lookup("458x", db, threadPool);
138                          lookup.doLookup();                                                                                        lookup.doLookup();                                                              
139                  }                  }
140    
141                    threadPool.shutdown();
142                                    
143                  long now = System.currentTimeMillis();                  long now = System.currentTimeMillis();
144                  long elapsed = now - start ;                  long elapsed = now - start ;
# Line 169  public class LookupMain { Line 175  public class LookupMain {
175                  int hours   = (int) ((milliseconds / (1000*60*60)) % 24);                  int hours   = (int) ((milliseconds / (1000*60*60)) % 24);
176                                    
177                  return String.format("%02d:%02d:%02d.%03d", hours, minutes, seconds, mseconds);                  return String.format("%02d:%02d:%02d.%03d", hours, minutes, seconds, mseconds);
178          }                }
179            
180            static class WorkerThreadFactory implements ThreadFactory {
181                    int count = 0;
182    
183                    @Override
184                    public Thread newThread(Runnable r) {
185                            return new Thread(r, "lookupWorker/" + count++);
186                    }      
187            }
188  }  }
Legend:
Removed from v.2244  
changed lines
  Added in v.2263
  ViewVC Help
Powered by ViewVC 1.1.20