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

forgot to empty queues

Browse Source
This commit is contained in:
Athou
2013-05-22 10:39:03 +02:00
parent 759abc41c3
commit cafcfc4c9f
1 changed files with 9 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -59,17 +59,23 @@ public class FeedRefreshTaskGiver {
int count = Math.min(100, 5 * backgroundThreads); int count = Math.min(100, 5 * backgroundThreads);
List<Feed> feeds = feedDAO.findNextUpdatable(count); List<Feed> feeds = feedDAO.findNextUpdatable(count);
feeds.addAll(addQueue); int size = addQueue.size();
for (int i = 0; i < size; i++) {
feeds.add(addQueue.poll());
}
for (Feed f : feeds) { for (Feed f : feeds) {
takeQueue.add(f); takeQueue.add(f);
f.setLastUpdated(Calendar.getInstance().getTime()); f.setLastUpdated(Calendar.getInstance().getTime());
} }
feeds.addAll(giveBackQueue); size = giveBackQueue.size();
for (int i = 0; i < size; i++) {
feeds.add(giveBackQueue.poll());
}
feedDAO.update(feeds); feedDAO.update(feeds);
feed = takeQueue.poll(); feed = takeQueue.poll();
} }
metricsBean.feedRefreshed(); metricsBean.feedRefreshed();