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

smaller session boundary

Browse Source
This commit is contained in:
Athou
2014-08-18 15:30:25 +02:00
parent ea68dbc56f
commit 17a5ef882f
1 changed files with 5 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -71,15 +71,13 @@ public class FeedRefreshTaskGiver implements Managed {
FeedRefreshContext context = new UnitOfWork<FeedRefreshContext>(sessionFactory) {
@Override
protected FeedRefreshContext runInSession() throws Exception {
FeedRefreshContext context = queues.take();
if (context != null) {
feedRefreshed.mark();
worker.updateFeed(context);
}
return context;
return queues.take();
}
}.run();
if (context == null) {
if (context != null) {
feedRefreshed.mark();
worker.updateFeed(context);
} else {
log.debug("nothing to do, sleeping for 15s");
threadWaited.mark();
try {