--- dao/FuldDaekningWorker/src/dk/daoas/fulddaekning/LookupWorker.java 2015/02/10 11:03:44 2262 +++ dao/FuldDaekningWorker/src/dk/daoas/fulddaekning/LookupWorker.java 2015/02/10 16:27:15 2263 @@ -2,6 +2,8 @@ import java.sql.SQLException; import java.util.Queue; +import java.util.concurrent.BrokenBarrierException; +import java.util.concurrent.CyclicBarrier; import java.util.logging.Level; import java.util.logging.Logger; @@ -17,10 +19,12 @@ int workerId; Lookup lookup; + CyclicBarrier barrier; - public LookupWorker(int workerId, Lookup lookup) { + public LookupWorker(int workerId, Lookup lookup, CyclicBarrier barrier) { this.workerId = workerId; this.lookup = lookup; + this.barrier = barrier; consts = Constants.getInstance(); } @@ -73,7 +77,14 @@ } } - + try { + barrier.await(); + } catch (BrokenBarrierException e) { + logger.log(Level.SEVERE, e.getMessage(), e); + System.exit(-1); + } catch(InterruptedException e) { + //Do nothing + } } LookupResult findBedsteAdresse(Adresse qAdresse, Adresse daekkede[]) {