Merge pull request #31 from lenguyenthanh/lilaism

Optimize with groupMapReduce
lichess-org · Apr 28, 2024 · 7dd761d · 7dd761d
2 parents 4e99d87 + 5567b53
commit 7dd761d
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/lila/src/main/scala/jvm.scala b/lila/src/main/scala/jvm.scala
@@ -10,12 +10,10 @@ object Jvm:
     override def toString = s"$name total: $total runnable: $running"
 
   def threadGroups(): List[ThreadGroup] = threadList()
-    .map { thread => """-\d+$""".r.replaceAllIn(thread.getName, "") -> thread.getState }
+    .map(thread => """-\d+$""".r.replaceAllIn(thread.getName, "") -> thread.getState)
     .groupBy(_._1)
     .view
-    .map { (name, states) =>
-      ThreadGroup(name, states.groupBy(_._2).view.mapValues(_.size).toMap)
-    }
+    .map((name, states) => ThreadGroup(name, states.groupMapReduce(_._2)(_ => 1)(_ + _)))
     .toList
     .sortBy(-_.total)