}
});
- loaderPool = Executors.newFixedThreadPool(15, new ThreadFactory() {
+ loaderPool = Executors.newFixedThreadPool(3, new ThreadFactory() {
int threadCount = 0;
@Override
public Thread newThread(Runnable r) {
public void await() throws InterruptedException {
latch.await();
loaderPool.shutdown();
- loaderPool.awaitTermination(30, TimeUnit.SECONDS);
+ loaderPool.awaitTermination(90, TimeUnit.SECONDS);
writerPool.shutdown();
- writerPool.awaitTermination(30, TimeUnit.SECONDS);
+ writerPool.awaitTermination(90, TimeUnit.SECONDS);
iterator.close();
long end = System.currentTimeMillis();
log.debug("Time to load presets: " + (end-startTime) + "ms " + presetCount + " loaded from " + fileCount + " files");
}
});
- 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();