src/Pure/System/isabelle_process.scala

unconditional Multithreading;
clarified files;

/*  Title:      Pure/System/isabelle_process.scala
    Author:     Makarius

Isabelle process wrapper.
*/

package isabelle


object Isabelle_Process
{
  def apply(
    receiver: Prover.Message => Unit = Console.println(_),
    prover_args: String = ""): Isabelle_Process =
  {
    val system_channel = System_Channel()
    val system_process =
      try {
        val script =
          File.shell_quote(Isabelle_System.getenv_strict("ISABELLE_PROCESS")) +
            " -P " + system_channel.server_name +
            (if (prover_args == "") "" else " " + prover_args)
        val process = Bash.process(null, null, false, "-c", script)
        process.stdin.close
        process
      }
      catch { case exn @ ERROR(_) => system_channel.accepted(); throw exn }

    new Isabelle_Process(receiver, system_channel, system_process)
  }
}

class Isabelle_Process private(
    receiver: Prover.Message => Unit,
    system_channel: System_Channel,
    system_process: Prover.System_Process)
  extends Prover(receiver, system_channel, system_process)
{
  def encode(s: String): String = Symbol.encode(s)
  def decode(s: String): String = Symbol.decode(s)
}