diff --git a/src/main/java/com/commafeed/backend/feeds/FeedRefreshUpdater.java b/src/main/java/com/commafeed/backend/feeds/FeedRefreshUpdater.java index 9bf33279..2147606e 100644 --- a/src/main/java/com/commafeed/backend/feeds/FeedRefreshUpdater.java +++ b/src/main/java/com/commafeed/backend/feeds/FeedRefreshUpdater.java @@ -56,7 +56,7 @@ public class FeedRefreshUpdater { @PostConstruct public void init() { ApplicationSettings settings = applicationSettingsService.get(); - int threads = Math.max(settings.getBackgroundThreads(), 1); + int threads = Math.max(settings.getDatabaseUpdateThreads(), 1); pool = new ThreadPoolExecutor(threads, threads, 0, TimeUnit.MILLISECONDS, new LinkedBlockingQueue()); pool.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy() { diff --git a/src/main/java/com/commafeed/backend/model/ApplicationSettings.java b/src/main/java/com/commafeed/backend/model/ApplicationSettings.java index 1a44f70d..b3061ab9 100644 --- a/src/main/java/com/commafeed/backend/model/ApplicationSettings.java +++ b/src/main/java/com/commafeed/backend/model/ApplicationSettings.java @@ -20,6 +20,7 @@ public class ApplicationSettings extends AbstractModel { private String googleClientId; private String googleClientSecret; private int backgroundThreads = 3; + private int databaseUpdateThreads = 1; private String smtpHost; private int smtpPort; private boolean smtpTls; @@ -153,4 +154,12 @@ public class ApplicationSettings extends AbstractModel { this.heavyLoad = heavyLoad; } + public int getDatabaseUpdateThreads() { + return databaseUpdateThreads; + } + + public void setDatabaseUpdateThreads(int databaseUpdateThreads) { + this.databaseUpdateThreads = databaseUpdateThreads; + } + } diff --git a/src/main/webapp/templates/admin.settings.html b/src/main/webapp/templates/admin.settings.html index fc22cf33..3be7d3c9 100644 --- a/src/main/webapp/templates/admin.settings.html +++ b/src/main/webapp/templates/admin.settings.html @@ -60,7 +60,7 @@
-
+
+ +
+ + Requires restart +
+