diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2018-05-23 21:02:45 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2018-05-23 21:02:45 +0200 |
commit | b4c468dcc75260a09a6cb6b2b6f1a279878228ca (patch) | |
tree | cfee9c6766903eafca8c1b19a75f46e8fb273b6c /configserver | |
parent | 76aba8b10ffbf5bcf7c23cc24ab38fda2ad0388d (diff) | |
parent | 270f52e776046ebef1e5c680b97671b08fc7aae7 (diff) |
Merge pull request #5911 from vespa-engine/hmusum/use-thread-pool-4
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.java | 7 |
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; |