garrettmills/commafeed
1
0
Fork 0
forked from Archives/Athou_commafeed
Code Pull Requests Activity

wait for a spot in the queue when full

Browse Source
This commit is contained in:
Athou
2013-05-23 16:52:50 +02:00
parent e8953378bb
commit 89ffd89a31
1 changed files with 10 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -2,7 +2,8 @@ package com.commafeed.backend.feeds;
import java.util.Collection; import java.util.Collection;
import java.util.List; import java.util.List;
import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.RejectedExecutionHandler;
import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
@@ -59,13 +60,17 @@ 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 ArrayBlockingQueue<Runnable>(
100 * threads)); 100 * threads));
pool.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy() { pool.setRejectedExecutionHandler(new RejectedExecutionHandler() {
@Override @Override
public void rejectedExecution(Runnable r, ThreadPoolExecutor e) { public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {
log.debug("Thread queue full, executing in own thread."); log.info("Thread queue full, waiting...");
super.rejectedExecution(r, e); try {
e.getQueue().put(r);
} catch (InterruptedException e1) {
log.error("Interrupted while waiting for queue.", e);
}
} }
}); });
} }