pool = new ThreadPoolExecutor(corePoolSize,maximumPoolSize,keepAliveTimeMs,TimeUnit.MILLISECONDS,queue);
CandidateFetcher fetcher = new CandidateFetcher(candidate); //implements Runnable
pool.execute(fetcher);
while(pool.getActiveCount()>0){
log.info("pool.getActiveCount(): "+pool.getActiveCount()+", waitUntilAllFetchesAreDone, go to sleep");
Thread.sleep(5000);
}
log.info("pool.getActiveCount(): 0, terminaron todos");
No hay comentarios:
Publicar un comentario