38 |
|
|
39 |
final static Logger logger = Logger.getLogger( LookupMain.class.toString() ); |
final static Logger logger = Logger.getLogger( LookupMain.class.toString() ); |
40 |
|
|
41 |
|
public static ProgressBar progressBar; |
42 |
|
|
43 |
|
|
44 |
static ThreadPoolExecutor threadPool; |
static ThreadPoolExecutor threadPool; |
45 |
|
|
112 |
antalIkkeDaekkede = ikkeDaekkede.size(); |
antalIkkeDaekkede = ikkeDaekkede.size(); |
113 |
logger.info("Antal ikke-daekkede: " + antalIkkeDaekkede ); |
logger.info("Antal ikke-daekkede: " + antalIkkeDaekkede ); |
114 |
|
|
115 |
|
progressBar = new ProgressBar( antalIkkeDaekkede ); |
116 |
|
|
117 |
|
|
118 |
|
|
119 |
boolean testRun= false; |
boolean testRun= false; |
171 |
CyclicBarrier barrier = new CyclicBarrier(LookupMain.max_workers + 1); |
CyclicBarrier barrier = new CyclicBarrier(LookupMain.max_workers + 1); |
172 |
|
|
173 |
for (int i=0; i<max_workers; i++) { |
for (int i=0; i<max_workers; i++) { |
174 |
LookupWorker worker = new LookupWorker(i, barrier, ikkeDaekkede, hoTrees,antalFundne,db,verbose,consts); |
LookupWorker worker = new LookupWorker(i, barrier, ikkeDaekkede, hoTrees,antalFundne,db,verbose,consts, progressBar); |
175 |
threadPool.submit( worker ); |
threadPool.submit( worker ); |
176 |
} |
} |
177 |
|
|