--- dao/FuldDaekningWorker/src/dk/daoas/fulddaekning/InputWorker.java 2014/04/30 13:34:24 2148 +++ dao/FuldDaekningWorker/src/dk/daoas/fulddaekning/InputWorker.java 2014/04/30 14:18:43 2149 @@ -15,6 +15,9 @@ public Queue queue = new ConcurrentLinkedQueue(); public boolean isDone = false; + public int largestWorkSetCount = 0; + public int largestWorkSetPostnr= 0; + public InputWorker(Database db) { this.db = db; @@ -57,6 +60,7 @@ workSet.queueSize = workSet.ikkeDaekkede.size(); + saveLargeWorkset( workSet ); queue.add(workSet); } else { //queue.wait(10); @@ -72,8 +76,15 @@ logger.log(Level.SEVERE, "Error during inputworker", e); System.exit(1); } + } + + private void saveLargeWorkset( WorkSet ws) { + int newSize = ws.daekkedeAdresser.size(); - + if (newSize > largestWorkSetCount) { + largestWorkSetCount = newSize; + largestWorkSetPostnr = ws.postnr; + } } }