src/Pure/System/isabelle_system.scala

 
   private def process_output(proc: Process): (String, Int) =
   {
     proc.getOutputStream.close
     val output = Source.fromInputStream(proc.getInputStream, charset).mkString
-    val rc = proc.waitFor
+    val rc =
+      try { proc.waitFor }
+      finally {
+        proc.getInputStream.close
+        proc.getErrorStream.close
+        proc.destroy
+        Thread.interrupted
+      }
     (output, rc)
   }
 }
 
 

 
     val dump = File.createTempFile("isabelle", null)
     try {
       val cmdline = shell_prefix :::
         List(isabelle_home + "/bin/isabelle", "getenv", "-d", dump.toString)
-      val proc = Isabelle_System.raw_execute(env0, true, cmdline: _*)
-      val (output, rc) = Isabelle_System.process_output(proc)
+      val (output, rc) =
+        Isabelle_System.process_output(Isabelle_System.raw_execute(env0, true, cmdline: _*))
       if (rc != 0) error(output)
 
       val entries =
         for (entry <- Source.fromFile(dump).mkString split "\0" if entry != "") yield {
           val i = entry.indexOf('=')

       val file = platform_file(dir + "/" + name)
       try { file.isFile && file.canRead && file.canExecute }
       catch { case _: SecurityException => false }
     }) match {
       case Some(dir) =>
-        val proc = execute(true, (List(platform_path(dir + "/" + name)) ++ args): _*)
-        Isabelle_System.process_output(proc)
+        Isabelle_System.process_output(
+          execute(true, (List(platform_path(dir + "/" + name)) ++ args): _*))
       case None => ("Unknown Isabelle tool: " + name, 2)
     }
   }
 
 

 
   def fifo_stream(fifo: String): BufferedInputStream =
   {
     // blocks until writer is ready
     val stream =
-      if (Platform.is_windows) execute(false, "cat", fifo).getInputStream
+      if (Platform.is_windows) {
+        val proc = execute(false, "cat", fifo)
+        proc.getOutputStream.close
+        proc.getErrorStream.close
+        proc.getInputStream
+      }
       else new FileInputStream(fifo)
     new BufferedInputStream(stream)
   }