--- dao/FuldDaekningWorker/src/dk/daoas/fulddaekning/LookupMain.java	2014/12/10 09:50:33	2241
+++ dao/FuldDaekningWorker/src/dk/daoas/fulddaekning/LookupMain.java	2015/02/09 13:21:39	2259
@@ -6,6 +6,7 @@
 import java.util.logging.FileHandler;
 import java.util.logging.Logger;
 import java.util.logging.SimpleFormatter;
+import java.util.concurrent.*;
 
 public class LookupMain {
 
@@ -29,6 +30,17 @@
 	static Statistik stoersteDataset = new Statistik();
 	
 	static Adresse[] alleDaekkedeAdresser;
+
+	static ThreadPoolExecutor threadPool;
+
+	private static void setupThreadPool() {
+		threadPool = (ThreadPoolExecutor) Executors.newFixedThreadPool(max_workers, new ThreadFactory() {
+			@Override
+			public Thread newThread(Runnable r) {
+				return new Thread(r, "lookupWorker");
+			}	
+		});
+	}
 	
 	
 	public static void main(String[] args) throws Exception {
@@ -52,7 +64,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);
@@ -100,7 +122,7 @@
 			db.resetResultTable();
 			
 			for(String postnr : postnumre) {
-				Lookup lookup = new Lookup(postnr, db);
+				Lookup lookup = new Lookup(postnr, db, threadPool);
 				lookup.doLookup();			
 			}
 			
@@ -121,7 +143,7 @@
 				logger.info( "AlleDaekkedeAdresser.length=" + alleDaekkedeAdresser.length);
 			}
 			
-			Lookup lookup = new Lookup("458x", db);
+			Lookup lookup = new Lookup("458x", db, threadPool);
 			lookup.doLookup();								
 		}