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

don't batch refresh more than 100 feeds

Browse Source
This commit is contained in:
Athou
2013-04-23 16:00:18 +02:00
parent 83946373d9
commit c71b0aee96
1 changed files with 10 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
src/main/java/com/commafeed/backend/feeds/FeedRefreshTaskGiver.java
View File

@@ -4,6 +4,7 @@ import java.util.Calendar;
import java.util.List; import java.util.List;
import java.util.Queue; import java.util.Queue;
import javax.annotation.PostConstruct;
import javax.ejb.Lock; import javax.ejb.Lock;
import javax.ejb.LockType; import javax.ejb.LockType;
import javax.ejb.Singleton; import javax.ejb.Singleton;
@@ -27,13 +28,21 @@ public class FeedRefreshTaskGiver {
@Inject @Inject
MetricsBean metricsBean; MetricsBean metricsBean;
private int backgroundThreads;
private Queue<Feed> queue = Queues.newConcurrentLinkedQueue(); private Queue<Feed> queue = Queues.newConcurrentLinkedQueue();
@PostConstruct
public void init() {
backgroundThreads = applicationSettingsService.get()
.getBackgroundThreads();
}
@Lock(LockType.WRITE) @Lock(LockType.WRITE)
public Feed take() { public Feed take() {
Feed feed = queue.poll(); Feed feed = queue.poll();
if (feed == null) { if (feed == null) {
List<Feed> feeds = feedDAO.findNextUpdatable(50); int count = Math.min(100, 5 * backgroundThreads);
List<Feed> feeds = feedDAO.findNextUpdatable(count);
for (Feed f : feeds) { for (Feed f : feeds) {
queue.add(f); queue.add(f);
f.setLastUpdated(Calendar.getInstance().getTime()); f.setLastUpdated(Calendar.getInstance().getTime());