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

small refactoring

Browse Source
This commit is contained in:
Athou
2013-05-30 13:18:26 +02:00
parent 401195176b
commit 63349d6e14
1 changed files with 31 additions and 26 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -57,41 +57,46 @@ public class FeedRefreshTaskGiver {
public synchronized Feed take() { public synchronized Feed take() {
Feed feed = takeQueue.poll(); Feed feed = takeQueue.poll();
if (feed == null) { if (feed == null) {
Date now = Calendar.getInstance().getTime(); refill();
int count = 3 * backgroundThreads;
List<Feed> feeds = feedDAO.findNextUpdatable(count);
int size = addQueue.size();
for (int i = 0; i < size; i++) {
feeds.add(addQueue.poll());
}
Map<Long, Feed> map = Maps.newHashMap();
for (Feed f : feeds) {
f.setLastUpdated(now);
map.put(f.getId(), f);
}
takeQueue.addAll(map.values());
size = giveBackQueue.size();
for (int i = 0; i < size; i++) {
Feed f = giveBackQueue.poll();
f.setLastUpdated(now);
map.put(f.getId(), f);
}
feedDAO.update(map.values());
feed = takeQueue.poll(); feed = takeQueue.poll();
} }
if (feed != null) { if (feed != null) {
metricsBean.feedRefreshed(); metricsBean.feedRefreshed();
} }
return feed; return feed;
} }
private void refill() {
Date now = Calendar.getInstance().getTime();
int count = 2 * backgroundThreads;
List<Feed> feeds = feedDAO.findNextUpdatable(count);
int size = addQueue.size();
for (int i = 0; i < size; i++) {
feeds.add(addQueue.poll());
}
Map<Long, Feed> map = Maps.newHashMap();
for (Feed f : feeds) {
f.setLastUpdated(now);
map.put(f.getId(), f);
}
takeQueue.addAll(map.values());
size = giveBackQueue.size();
for (int i = 0; i < size; i++) {
Feed f = giveBackQueue.poll();
f.setLastUpdated(now);
map.put(f.getId(), f);
}
feedDAO.update(map.values());
}
public void giveBack(Feed feed) { public void giveBack(Feed feed) {
giveBackQueue.add(feed); giveBackQueue.add(feed);
} }