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

small optimizations

Browse Source
This commit is contained in:
Athou
2013-04-22 10:23:53 +02:00
parent bb5d76109a
commit 839beb5d14
1 changed files with 14 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
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,29 +28,30 @@ public class FeedRefreshTaskGiver {
@Inject @Inject
MetricsBean metricsBean; MetricsBean metricsBean;
private int backgroundThreads;
private Queue<Feed> queue = Queues.newConcurrentLinkedQueue(); private Queue<Feed> queue = Queues.newConcurrentLinkedQueue();
@Lock(LockType.WRITE) @PostConstruct
public void add(Feed feed) { public void init() {
queue.add(feed); backgroundThreads = applicationSettingsService.get()
feed.setLastUpdated(Calendar.getInstance().getTime()); .getBackgroundThreads();
feedDAO.update(feed);
} }
@Lock(LockType.WRITE) @Lock(LockType.WRITE)
public Feed take() { public Feed take() {
if (queue.peek() == null) { Feed feed = queue.poll();
if (feed == null) {
List<Feed> feeds = feedDAO List<Feed> feeds = feedDAO
.findNextUpdatable(50 * applicationSettingsService.get() .findNextUpdatable(50 * backgroundThreads);
.getBackgroundThreads()); for (Feed f : feeds) {
for (Feed feed : feeds) { queue.add(f);
queue.add(feed); f.setLastUpdated(Calendar.getInstance().getTime());
feed.setLastUpdated(Calendar.getInstance().getTime());
} }
feedDAO.update(feeds); feedDAO.update(feeds);
feed = queue.poll();
} }
metricsBean.feedRefreshed(); metricsBean.feedRefreshed();
return queue.poll(); return feed;
} }
} }