diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2022-11-11 11:20:36 +0100 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2022-11-11 11:20:36 +0100 |
commit | d2e457ca7523c32825402eedf0052576034feccf (patch) | |
tree | 2d14ba09fcd09a53bddb4880cacc2e9a3c633262 /container-disc | |
parent | 2a23dab552cb9fc98eb54d7351782ce01f171712 (diff) |
Use a thread executor to fire off subcribes to multiple keys concurrently.
Diffstat (limited to 'container-disc')
-rw-r--r-- | container-disc/src/main/java/com/yahoo/container/jdisc/ConfiguredApplication.java | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/container-disc/src/main/java/com/yahoo/container/jdisc/ConfiguredApplication.java b/container-disc/src/main/java/com/yahoo/container/jdisc/ConfiguredApplication.java index 625bd87c2db..9c2d703e1a8 100644 --- a/container-disc/src/main/java/com/yahoo/container/jdisc/ConfiguredApplication.java +++ b/container-disc/src/main/java/com/yahoo/container/jdisc/ConfiguredApplication.java @@ -452,6 +452,7 @@ public final class ConfiguredApplication implements Application { startAndStopServers(List.of()); startAndRemoveClients(List.of()); activateContainer(null, () -> log.info("Last active container generation has terminated")); + subscriberFactory.close(); nonTerminatedContainerTracker.arriveAndAwaitAdvance(); } |