Archives/Athou_commafeed
1
0
Fork 1
mirror of https://github.com/Athou/commafeed.git synced 2026-03-21 21:37:29 +00:00
Code Issues Packages Projects Releases Wiki Activity

actually set a capacity limit to the queue

Browse Source
This commit is contained in:
Athou
2013-05-23 12:08:16 +02:00
parent 9ee2667728
commit 0d65471c83
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/java/com/commafeed/backend/feeds/FeedRefreshUpdater.java
View File

@@ -59,7 +59,8 @@ public class FeedRefreshUpdater {
int threads = Math.max(settings.getDatabaseUpdateThreads(), 1); int threads = Math.max(settings.getDatabaseUpdateThreads(), 1);
log.info("Creating database pool with {} threads", threads); log.info("Creating database pool with {} threads", threads);
pool = new ThreadPoolExecutor(threads, threads, 0, pool = new ThreadPoolExecutor(threads, threads, 0,
TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>()); TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>(
100 * threads));
pool.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy() { pool.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy() {
@Override @Override
public void rejectedExecution(Runnable r, ThreadPoolExecutor e) { public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {