summaryrefslogtreecommitdiffstats
path: root/configserver
diff options
context:
space:
mode:
authorHarald Musum <musum@oath.com>2018-05-23 12:35:53 +0200
committerHarald Musum <musum@oath.com>2018-05-23 12:35:53 +0200
commit270f52e776046ebef1e5c680b97671b08fc7aae7 (patch)
treec1a19f8bbd5709145c077ca0a5a9d6d4de8fd5c8 /configserver
parentbbfa8456064e99c65ea4e78902d4fb02591ee7f3 (diff)
Use a shared thread pool instead of creating a new for every session
Diffstat (limited to 'configserver')
-rw-r--r--configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionStateWatcher.java7
1 files changed, 4 insertions, 3 deletions
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionStateWatcher.java b/configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionStateWatcher.java
index ed1eba58dfb..117930c6d7d 100644
--- a/configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionStateWatcher.java
+++ b/configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionStateWatcher.java
@@ -23,18 +23,19 @@ import java.util.logging.Logger;
public class SessionStateWatcher implements NodeCacheListener {
private static final Logger log = Logger.getLogger(SessionStateWatcher.class.getName());
+ // One thread pool for all instances of this class
+ private static final Executor executor = Executors.newCachedThreadPool(ThreadFactoryFactory.getDaemonThreadFactory(SessionStateWatcher.class.getName()));
+
private final Curator.FileCache fileCache;
private final ReloadHandler reloadHandler;
private final RemoteSession session;
private final MetricUpdater metrics;
- private final Executor executor;
+
public SessionStateWatcher(Curator.FileCache fileCache,
ReloadHandler reloadHandler,
RemoteSession session,
MetricUpdater metrics) {
- executor = Executors.newSingleThreadExecutor(
- ThreadFactoryFactory.getThreadFactory(SessionStateWatcher.class.getName() + "-" + session));
this.fileCache = fileCache;
this.reloadHandler = reloadHandler;
this.session = session;