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

make sure we don't refresh a feed twice in a row

Browse Source
This commit is contained in:
Athou
2023-05-25 09:02:01 +02:00
parent a546ae0d53
commit a08ea27c2f
1 changed files with 13 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
commafeed-server/src/main/java/com/commafeed/backend/feed/FeedRefreshEngine.java
View File

@@ -119,14 +119,24 @@ public class FeedRefreshEngine implements Managed {
} }
public void refreshImmediately(Feed feed) { public void refreshImmediately(Feed feed) {
// remove the feed from the queue if it was already queued to avoid refreshing it twice
queue.removeIf(f -> f.getId().equals(feed.getId()));
queue.addFirst(feed); queue.addFirst(feed);
} }
private void refillQueueAsync() { private void refillQueueAsync() {
CompletableFuture.runAsync(() -> { CompletableFuture.runAsync(() -> {
if (queue.isEmpty()) { if (!queue.isEmpty()) {
refill.mark(); return;
queue.addAll(getNextUpdatableFeeds(getBatchSize())); }
refill.mark();
for (Feed feed : getNextUpdatableFeeds(getBatchSize())) {
// add the feed only if it was not already queued
if (queue.stream().noneMatch(f -> f.getId().equals(feed.getId()))) {
queue.addLast(feed);
}
} }
}, refillExecutor).whenComplete((data, ex) -> { }, refillExecutor).whenComplete((data, ex) -> {
if (ex != null) { if (ex != null) {