80 |
Constants.init(distributor); |
Constants.init(distributor); |
81 |
Constants consts = Constants.getInstance(); |
Constants consts = Constants.getInstance(); |
82 |
|
|
|
|
|
|
Database db = new Database(conf); |
|
|
Queue<Adresse> ikkeDaekkede = db.hentAlleIkkedaekkedeAdresser(consts.getMinPostnr(), consts.getMaxPostnr() ); |
|
|
antalIkkeDaekkede = ikkeDaekkede.size(); |
|
|
logger.info("Antal ikke-daekkede: " + antalIkkeDaekkede ); |
|
|
|
|
|
|
|
83 |
max_workers = Integer.parseInt( conf.getSafeProperty("MAX_WORKERS") ); |
max_workers = Integer.parseInt( conf.getSafeProperty("MAX_WORKERS") ); |
84 |
if (max_workers <= 0) { |
if (max_workers <= 0) { |
85 |
logger.info("!!! AUTO-DETECT MAX_WORKERS !!!"); |
logger.info("!!! AUTO-DETECT MAX_WORKERS !!!"); |
92 |
logger.info("Starting with MAX_WORKERS:" + max_workers); |
logger.info("Starting with MAX_WORKERS:" + max_workers); |
93 |
setupThreadPool(); |
setupThreadPool(); |
94 |
|
|
95 |
|
|
96 |
|
Database db = new Database(conf); |
97 |
|
Queue<Adresse> ikkeDaekkede = db.hentAlleIkkedaekkedeAdresser(consts.getMinPostnr(), consts.getMaxPostnr() ); |
98 |
|
antalIkkeDaekkede = ikkeDaekkede.size(); |
99 |
|
logger.info("Antal ikke-daekkede: " + antalIkkeDaekkede ); |
100 |
|
|
101 |
|
|
102 |
|
|
103 |
boolean testRun= false; |
boolean testRun= false; |
104 |
|
|
105 |
AtomicInteger antalFundne = new AtomicInteger(0); |
AtomicInteger antalFundne = new AtomicInteger(0); |