--- dao/FuldDaekningWorker/src/dk/daoas/fulddaekning/LookupMain.java 2015/02/09 14:00:53 2260 +++ dao/FuldDaekningWorker/src/dk/daoas/fulddaekning/LookupMain.java 2015/03/03 08:14:09 2422 @@ -2,11 +2,13 @@ import java.io.File; import java.io.FileReader; -import java.util.List; +import java.util.Set; +import java.util.concurrent.Executors; +import java.util.concurrent.ThreadFactory; +import java.util.concurrent.ThreadPoolExecutor; import java.util.logging.FileHandler; import java.util.logging.Logger; import java.util.logging.SimpleFormatter; -import java.util.concurrent.*; public class LookupMain { @@ -29,7 +31,7 @@ static Statistik mestBrugteTid = new Statistik(); static Statistik stoersteDataset = new Statistik(); - static Adresse[] alleDaekkedeAdresser; + private static Adresse[] alleDaekkedeAdresser; static ThreadPoolExecutor threadPool; @@ -85,8 +87,7 @@ Constants consts = Constants.getInstance(); Database db = new Database(conf); - - + db.hentAlleIkkedaekkedeAdresser(consts.getMinPostnr(), consts.getMaxPostnr() ); boolean testRun= false; @@ -97,26 +98,24 @@ if (testRun == false) { logger.info("Finder postnumre"); - List postnumre = db.hentPostnumre(); + Set postnumre = db.hentPostnumreCache(); // Først validerer vi BBox på alle postnummre, for at undgå fuldt stop midt i beregningen - for(String postnr : postnumre) { // + for(int postnr : postnumre) { // logger.info("Validerer BBox for " + postnr); BoundingBox bbox = db.getBoundingbox(postnr); bbox.validateBbox(); } - if (consts.doExtendedLookup()) { - logger.info("Henter alle daekkede adresser"); - alleDaekkedeAdresser = db.hentAlleDaekkedeAdresser(); - logger.info( "AlleDaekkedeAdresser.length=" + alleDaekkedeAdresser.length); - } - + + logger.info("Henter alle daekkede adresser"); + alleDaekkedeAdresser = db.hentAlleDaekkedeAdresser(); + logger.info( "AlleDaekkedeAdresser.length=" + alleDaekkedeAdresser.length); //pre-check er ok - reset tmp tabel og start søgningen db.resetResultTable(); - for(String postnr : postnumre) { + for(int postnr : postnumre) { Lookup lookup = new Lookup(postnr, db, threadPool); lookup.doLookup(); } @@ -133,12 +132,12 @@ /// Test db.resetResultTable(); - if (consts.doExtendedLookup()) { - alleDaekkedeAdresser = db.hentAlleDaekkedeAdresser(); - logger.info( "AlleDaekkedeAdresser.length=" + alleDaekkedeAdresser.length); - } + + alleDaekkedeAdresser = db.hentAlleDaekkedeAdresser(); + logger.info( "AlleDaekkedeAdresser.length=" + alleDaekkedeAdresser.length); + - Lookup lookup = new Lookup("458x", db, threadPool); + Lookup lookup = new Lookup(2700, db, threadPool); lookup.doLookup(); }