Merge pull request #1453 from rumakt/feature/1452-excess-cpu-consumption

Sleep between sessionContainer update passes.
finos · Aug 9, 2024 · c1efc07 · c1efc07
2 parents bd0481d + a193769
commit c1efc07
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/vuu/src/main/scala/org/finos/vuu/core/VuuServer.scala b/vuu/src/main/scala/org/finos/vuu/core/VuuServer.scala
@@ -70,7 +70,7 @@ class VuuServer(config: VuuServerConfig)(implicit lifecycle: LifecycleContainer,
   private final val joinProviderRunner = new LifeCycleRunner("joinProviderRunner", () => joinProvider.runOnce())
   lifecycle(joinProviderRunner).dependsOn(joinProvider)
 
-  private final  val handlerRunner = new LifeCycleRunner("sessionRunner", () => sessionContainer.runOnce(), minCycleTime = -1)
+  private final  val handlerRunner = new LifeCycleRunner("sessionRunner", () => sessionContainer.runOnce(), minCycleTime = 1)
   lifecycle(handlerRunner).dependsOn(joinProviderRunner)
 
   private val viewPortRunner = if(config.threading.viewportThreads == 1){

diff --git a/vuu/src/main/scala/org/finos/vuu/net/ClientConnectionCreator.scala b/vuu/src/main/scala/org/finos/vuu/net/ClientConnectionCreator.scala
@@ -231,7 +231,9 @@ class ClientSessionContainerImpl() extends ClientSessionContainer with StrictLog
   }
 
   def runOnce(): Unit = {
-    SetHasAsScala(sessions.entrySet()).asScala.foreach(entry => entry.getValue.sendUpdates())
+    if(!sessions.isEmpty) {
+      SetHasAsScala(sessions.entrySet()).asScala.foreach(entry => entry.getValue.sendUpdates())
+    }
   }
 }