diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2021-08-31 07:02:26 +0200 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2021-08-31 07:16:53 +0200 |
commit | 2c10a25de97eb16f9b110b622aece07a9fef878f (patch) | |
tree | 8a316a31cb8167d456a05849d00828085768faba /configserver | |
parent | f8983c8e6309505bf30357b01beb5add06c3fd6e (diff) |
bootstrapExecutor only need method local scope.
Diffstat (limited to 'configserver')
-rw-r--r-- | configserver/src/main/java/com/yahoo/vespa/config/server/tenant/TenantRepository.java | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/tenant/TenantRepository.java b/configserver/src/main/java/com/yahoo/vespa/config/server/tenant/TenantRepository.java index 8641b7dcffe..7c6d1dea3a4 100644 --- a/configserver/src/main/java/com/yahoo/vespa/config/server/tenant/TenantRepository.java +++ b/configserver/src/main/java/com/yahoo/vespa/config/server/tenant/TenantRepository.java @@ -115,7 +115,6 @@ public class TenantRepository { private final ModelFactoryRegistry modelFactoryRegistry; private final ConfigDefinitionRepo configDefinitionRepo; private final ReloadListener reloadListener; - private final ExecutorService bootstrapExecutor; private final ScheduledExecutorService checkForRemovedApplicationsService = new ScheduledThreadPoolExecutor(1, new DaemonThreadFactory("check for removed applications")); private final Curator.DirectoryCache directoryCache; @@ -181,8 +180,6 @@ public class TenantRepository { ZookeeperServerConfig zookeeperServerConfig) { this.hostRegistry = hostRegistry; this.configserverConfig = configserverConfig; - this.bootstrapExecutor = Executors.newFixedThreadPool(configserverConfig.numParallelTenantLoaders(), - new DaemonThreadFactory("bootstrap-tenant-")); this.curator = curator; this.metrics = metrics; metricUpdater = metrics.getOrCreateMetricUpdater(Collections.emptyMap()); @@ -271,6 +268,8 @@ public class TenantRepository { } private void bootstrapTenants() { + ExecutorService bootstrapExecutor = Executors.newFixedThreadPool(configserverConfig.numParallelTenantLoaders(), + new DaemonThreadFactory("bootstrap-tenant-")); // Keep track of tenants created Map<TenantName, Future<?>> futures = new HashMap<>(); readTenantsFromZooKeeper(curator).forEach(t -> futures.put(t, bootstrapExecutor.submit(() -> bootstrapTenant(t)))); |