(*  Title:      Pure/Concurrent/simple_thread.ML

    Author:     Makarius

Simplified thread operations.

*)

signature SIMPLE_THREAD =

sig

  val fork: bool -> (unit -> unit) -> Thread.thread

  val interrupt: Thread.thread -> unit

  val synchronized: string -> Mutex.mutex -> (unit -> 'a) -> 'a

end;

structure SimpleThread: SIMPLE_THREAD =

struct

fun fork interrupts body =

  Thread.fork (fn () => exception_trace (fn () => body ()),

    if interrupts then Multithreading.regular_interrupts else Multithreading.no_interrupts);

fun interrupt thread = Thread.interrupt thread handle Thread _ => ();

(* basic synchronization *)

fun synchronized name lock e = Exn.release (uninterruptible (fn restore_attributes => fn () =>

  let

    val immediate =

      if Mutex.trylock lock then true

      else

        let

          val _ = Multithreading.tracing 5 (fn () => name ^ ": locking ...");

          val time = Multithreading.real_time Mutex.lock lock;

          val _ = Multithreading.tracing_time true time

            (fn () => name ^ ": locked after " ^ Time.toString time);

        in false end;

    val result = Exn.capture (restore_attributes e) ();

    val _ =

      if immediate then () else Multithreading.tracing 5 (fn () => name ^ ": unlocking ...");

    val _ = Mutex.unlock lock;

  in result end) ());

end;