diff --git a/src/main/java/com/commafeed/backend/feeds/FeedRefreshUpdater.java b/src/main/java/com/commafeed/backend/feeds/FeedRefreshUpdater.java index ec21e7ee..7450a619 100644 --- a/src/main/java/com/commafeed/backend/feeds/FeedRefreshUpdater.java +++ b/src/main/java/com/commafeed/backend/feeds/FeedRefreshUpdater.java @@ -73,7 +73,7 @@ public class FeedRefreshUpdater { ApplicationSettings settings = applicationSettingsService.get(); int threads = Math.max(settings.getDatabaseUpdateThreads(), 1); log.info("Creating database pool with {} threads", threads); - pool = new FeedRefreshExecutor("FeedRefreshUpdater", threads, 500 * threads); + pool = new FeedRefreshExecutor("feed-refresh-updater", threads, 500 * threads); locks = Striped.lazyWeakLock(threads * 100000); } diff --git a/src/main/java/com/commafeed/backend/feeds/FeedRefreshWorker.java b/src/main/java/com/commafeed/backend/feeds/FeedRefreshWorker.java index d67c1639..a5393d9f 100644 --- a/src/main/java/com/commafeed/backend/feeds/FeedRefreshWorker.java +++ b/src/main/java/com/commafeed/backend/feeds/FeedRefreshWorker.java @@ -53,7 +53,7 @@ public class FeedRefreshWorker { ApplicationSettings settings = applicationSettingsService.get(); int threads = settings.getBackgroundThreads(); log.info("Creating refresh worker pool with {} threads", threads); - pool = new FeedRefreshExecutor("FeedRefreshUpdater", threads, + pool = new FeedRefreshExecutor("feed-refresh-worker", threads, 20 * threads); }