clarified signature;
authorwenzelm
Sat, 07 Aug 2021 19:58:38 +0200
changeset 74410 8a5e02ef975c
parent 74409 3314559ef095
child 74411 bba35ad317ab
clarified signature;
src/Pure/Concurrent/consumer_thread.scala
src/Pure/General/file_watcher.scala
src/Pure/PIDE/prover.scala
src/Pure/System/command_line.scala
src/Pure/Tools/server.scala
--- a/src/Pure/Concurrent/consumer_thread.scala	Sat Aug 07 19:29:41 2021 +0200
+++ b/src/Pure/Concurrent/consumer_thread.scala	Sat Aug 07 19:58:38 2021 +0200
@@ -119,6 +119,6 @@
   def shutdown(): Unit =
   {
     synchronized { if (is_active) { active = false; mailbox.send(None) } }
-    thread.join
+    thread.join()
   }
 }
--- a/src/Pure/General/file_watcher.scala	Sat Aug 07 19:29:41 2021 +0200
+++ b/src/Pure/General/file_watcher.scala	Sat Aug 07 19:58:38 2021 +0200
@@ -129,7 +129,7 @@
     override def shutdown(): Unit =
     {
       watcher_thread.interrupt()
-      watcher_thread.join
+      watcher_thread.join()
       delay_changed.revoke()
     }
   }
--- a/src/Pure/PIDE/prover.scala	Sat Aug 07 19:29:41 2021 +0200
+++ b/src/Pure/PIDE/prover.scala	Sat Aug 07 19:58:38 2021 +0200
@@ -162,7 +162,7 @@
       val result = process_result.join
       system_output("process terminated")
       command_input_close()
-      for (thread <- List(stdout, stderr, message)) thread.join
+      for (thread <- List(stdout, stderr, message)) thread.join()
       system_output("process_manager terminated")
       exit_message(result)
     }
--- a/src/Pure/System/command_line.scala	Sat Aug 07 19:29:41 2021 +0200
+++ b/src/Pure/System/command_line.scala	Sat Aug 07 19:58:38 2021 +0200
@@ -34,7 +34,7 @@
           }
         sys.exit(rc)
       }
-    thread.join
+    thread.join()
   }
 
   def ML_tool(body: List[String]): String =
--- a/src/Pure/Tools/server.scala	Sat Aug 07 19:29:41 2021 +0200
+++ b/src/Pure/Tools/server.scala	Sat Aug 07 19:58:38 2021 +0200
@@ -150,8 +150,8 @@
       }
 
     def start(): Unit = thread
-    def join: Unit = thread.join
-    def stop(): Unit = { socket.close(); join }
+    def join(): Unit = thread.join()
+    def stop(): Unit = { socket.close(); join() }
   }
 
 
@@ -255,7 +255,7 @@
     def close(): Unit =
     {
       while(_tasks.change_result(tasks => { tasks.foreach(_.cancel()); (tasks.nonEmpty, tasks) }))
-      { _tasks.value.foreach(_.join) }
+      { _tasks.value.foreach(_.join()) }
     }
   }
 
@@ -307,8 +307,8 @@
       progress.stop()
       context.remove_task(task)
     }
-    def start: Unit = thread
-    def join: Unit = thread.join
+    def start(): Unit = thread
+    def join(): Unit = thread.join()
   }
 
 
@@ -510,7 +510,7 @@
         if (console) {
           using(server_info.connection())(connection => connection.tty_loop().join)
         }
-        server.foreach(_.join)
+        server.foreach(_.join())
       }
     })
 }
@@ -546,7 +546,7 @@
     }
   }
 
-  override def join: Unit = { super.join; shutdown() }
+  override def join(): Unit = { super.join(); shutdown() }
 
   override def handle(connection: Server.Connection): Unit =
   {
@@ -572,7 +572,7 @@
                       Exn.capture { cmd.command_body((context, arg)) } match {
                         case Exn.Res(task: Server.Task) =>
                           connection.reply_ok(JSON.Object(task.ident))
-                          task.start
+                          task.start()
                         case Exn.Res(res) => connection.reply_ok(res)
                         case Exn.Exn(exn) =>
                           val err = Server.json_error(exn)