diff --git a/src/main/java/com/commafeed/backend/feeds/FeedRefreshUpdater.java b/src/main/java/com/commafeed/backend/feeds/FeedRefreshUpdater.java index ffd60218..32145def 100644 --- a/src/main/java/com/commafeed/backend/feeds/FeedRefreshUpdater.java +++ b/src/main/java/com/commafeed/backend/feeds/FeedRefreshUpdater.java @@ -59,7 +59,8 @@ public class FeedRefreshUpdater { int threads = Math.max(settings.getDatabaseUpdateThreads(), 1); log.info("Creating database pool with {} threads", threads); pool = new ThreadPoolExecutor(threads, threads, 0, - TimeUnit.MILLISECONDS, new LinkedBlockingQueue()); + TimeUnit.MILLISECONDS, new LinkedBlockingQueue( + 100 * threads)); pool.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy() { @Override public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {