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

parrallel delete

Browse Source
This commit is contained in:
Athou
2013-07-10 10:36:53 +02:00
parent fafc66eb8e
commit d293926624
1 changed files with 12 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
src/main/java/com/commafeed/backend/DatabaseCleaner.java
View File

@@ -75,15 +75,19 @@ public class DatabaseCleaner {
long total = 0; long total = 0;
int deleted = -1; int deleted = -1;
do { do {
List<FeedCount> fcs = feedDAO.findDuplicates(0, 1, 1); List<FeedCount> fcs = feedDAO.findDuplicates(0, 10, 1);
deleted = fcs.size(); deleted = fcs.size();
for (FeedCount fc : fcs) { for (final FeedCount fc : fcs) {
Feed into = feedDAO.findById(fc.feeds.get(0).getId()); new Thread() {
List<Feed> feeds = Lists.newArrayList(); public void run() {
for (Feed feed : fc.feeds) { Feed into = feedDAO.findById(fc.feeds.get(0).getId());
feeds.add(feedDAO.findById(feed.getId())); List<Feed> feeds = Lists.newArrayList();
} for (Feed feed : fc.feeds) {
mergeFeeds(into, feeds); feeds.add(feedDAO.findById(feed.getId()));
}
mergeFeeds(into, feeds);
};
}.start();
} }
total += deleted; total += deleted;
log.info("merged {} feeds", total); log.info("merged {} feeds", total);