--- dao/FuldDaekningWorker/src/dk/daoas/fulddaekning/LookupMain.java	2014/12/10 09:50:33	2241
+++ dao/FuldDaekningWorker/src/dk/daoas/fulddaekning/LookupMain.java	2015/06/09 19:42:00	2575
@@ -2,7 +2,10 @@
 
 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;
@@ -28,7 +31,13 @@
 	static Statistik mestBrugteTid = new Statistik();
 	static Statistik stoersteDataset = new Statistik();
 	
-	static Adresse[] alleDaekkedeAdresser;
+	private static Adresse[] alleDaekkedeAdresser;
+
+	static ThreadPoolExecutor threadPool;
+
+	private static void setupThreadPool() {
+		threadPool = (ThreadPoolExecutor) Executors.newFixedThreadPool(max_workers, new WorkerThreadFactory() );
+	}
 	
 	
 	public static void main(String[] args) throws Exception {
@@ -52,7 +61,17 @@
 		conf.load( new FileReader(confFile) );
 		
 		max_workers = Integer.parseInt( conf.getSafeProperty("MAX_WORKERS") );
+		if (max_workers <= 0) {
+			logger.info("!!! AUTO-DETECT MAX_WORKERS !!!");
+			int cores = Runtime.getRuntime().availableProcessors();
+			cores -= 1;//Efterlad 1 core/cpu i reserve til systemet
+			
+			max_workers = Math.max(1, cores); //Dog skal der som minimum være 1 core til beregning 
+			
+		}
 		logger.info("Starting with MAX_WORKERS:" + max_workers);
+		setupThreadPool();
+		
 		
 		verbose = Boolean.parseBoolean( conf.getSafeProperty("VERBOSE") );
 		logger.info("Starting with VERBOSE:" + verbose);
@@ -68,8 +87,7 @@
 		Constants consts = Constants.getInstance();
 		
 		Database db = new Database(conf);
-		
-		
+		db.hentAlleIkkedaekkedeAdresser(consts.getMinPostnr(), consts.getMaxPostnr() );
 
 		
 		boolean testRun= false;
@@ -80,27 +98,25 @@
 		if (testRun == false) {
 		
 			logger.info("Finder postnumre");
-			List<String> postnumre = db.hentPostnumre();
+			Set<Short> postnumre = db.hentPostnumreCache();
 			
 			// Først validerer vi BBox på alle postnummre, for at undgå fuldt stop midt i beregningen
-			for(String postnr : postnumre) { //
+			for(short 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) {
-				Lookup lookup = new Lookup(postnr, db);
+			for(short postnr : postnumre) {
+				Lookup lookup = new Lookup(postnr, db, threadPool);
 				lookup.doLookup();			
 			}
 			
@@ -116,14 +132,16 @@
 			/// Test
 			db.resetResultTable();
 			
-			if (consts.doExtendedLookup()) {
-				alleDaekkedeAdresser = db.hentAlleDaekkedeAdresser();
-				logger.info( "AlleDaekkedeAdresser.length=" + alleDaekkedeAdresser.length);
-			}
-			
-			Lookup lookup = new Lookup("458x", db);
+
+			alleDaekkedeAdresser = db.hentAlleDaekkedeAdresser();
+			logger.info( "AlleDaekkedeAdresser.length=" + alleDaekkedeAdresser.length);
+
+			short post = (short) 2700;			
+			Lookup lookup = new Lookup(post, db, threadPool);
 			lookup.doLookup();								
 		}
+
+		threadPool.shutdown();
 		
 		long now = System.currentTimeMillis();
 		long elapsed = now - start ;
@@ -160,5 +178,14 @@
 		int hours   = (int) ((milliseconds / (1000*60*60)) % 24);
 		
 		return String.format("%02d:%02d:%02d.%03d", hours, minutes, seconds, mseconds);
-	}	
+	}
+	
+	static class WorkerThreadFactory implements ThreadFactory {
+		int count = 0;
+
+		@Override
+		public Thread newThread(Runnable r) {
+			return new Thread(r, "lookupWorker/" + count++);
+		}	
+	}
 }