}
});
- loaderPool = new ThreadPoolExecutor(25,25, 2, TimeUnit.SECONDS,
+ loaderPool = new ThreadPoolExecutor(10,10, 2, TimeUnit.SECONDS,
new LinkedBlockingQueue<Runnable>(),
new ThreadFactory() {
int threadCount = 0;
private void waitForFinish() throws InterruptedException {
try {
loaderPool.shutdown();
- loaderPool.awaitTermination(30, TimeUnit.SECONDS);
+ loaderPool.awaitTermination(90, TimeUnit.SECONDS);
writerThread.shutdown();
- writerThread.awaitTermination(30, TimeUnit.SECONDS);
+ writerThread.awaitTermination(90, TimeUnit.SECONDS);
}
finally {
iterator.close();