# HG changeset patch
# User wenzelm
# Date 1676288875 -3600
# Node ID ab13ac27c74a0dbe6f35b1f3cc177fd483260b13
# Parent  3f2b1419f5982f9ccb3f9059ac0c6cd0d560fab5
clarified signature: more explicit synchronized operations;

diff -r 3f2b1419f598 -r ab13ac27c74a src/Pure/Tools/build_process.scala
--- a/src/Pure/Tools/build_process.scala	Mon Feb 13 12:36:49 2023 +0100
+++ b/src/Pure/Tools/build_process.scala	Mon Feb 13 12:47:55 2023 +0100
@@ -190,6 +190,10 @@
       Set.from(for { job <- _running.valuesIterator; i <- job.numa_node } yield i))
   }
 
+  private def test_running(): Boolean = synchronized { !_build_graph.is_empty }
+
+  private def stop_running(): Unit = synchronized { _running.valuesIterator.foreach(_.terminate()) }
+
   private def job_running(name: String, job: Build_Job): Build_Job = synchronized {
     _running += (name -> job)
     job
@@ -208,6 +212,10 @@
     _results += (name -> Build_Process.Result(current, output_heap, process_result))
   }
 
+  private def get_results(names: List[String]): List[Build_Process.Result] = synchronized {
+    names.map(_results.apply)
+  }
+
   private def session_finished(session_name: String, process_result: Process_Result): String =
     "Finished " + session_name + " (" + process_result.timing.message_resources + ")"
 
@@ -275,8 +283,9 @@
 
   private def start_job(session_name: String): Unit = {
     val ancestor_results =
-      build_deps.sessions_structure.build_requirements(List(session_name)).
-        filterNot(_ == session_name).map(_results(_))
+      get_results(
+        build_deps.sessions_structure.build_requirements(List(session_name)).
+          filterNot(_ == session_name))
     val input_heaps =
       if (ancestor_results.isEmpty) {
         SHA1.shasum_meta_info(SHA1.digest(Path.explode("$POLYML_EXE")))
@@ -354,8 +363,8 @@
     }
 
   def run(): Map[String, Build_Process.Result] = {
-    while (synchronized { !_build_graph.is_empty }) {
-      if (progress.stopped) synchronized { _running.valuesIterator.foreach(_.terminate()) }
+    while (test_running()) {
+      if (progress.stopped) stop_running()
 
       synchronized { _running } .find({ case (_, job) => job.is_finished }) match {
         case Some((session_name, job)) => finish_job(session_name, job)