59 lines
1.8 KiB
Plaintext
59 lines
1.8 KiB
Plaintext
(***********************************************************************)
|
|
(* *)
|
|
(* Caml Special Light *)
|
|
(* *)
|
|
(* Xavier Leroy and Pascal Cuoq, projet Cristal, INRIA Rocquencourt *)
|
|
(* *)
|
|
(* Copyright 1995 Institut National de Recherche en Informatique et *)
|
|
(* Automatique. Distributed only by permission. *)
|
|
(* *)
|
|
(***********************************************************************)
|
|
|
|
(* $Id$ *)
|
|
|
|
#ifdef WIN32
|
|
|
|
type t = { mut: Mutex.t; mutable waiting: Thread.t list }
|
|
|
|
let create () =
|
|
let m =
|
|
try
|
|
Mutex.create()
|
|
with Sys_error _ ->
|
|
raise(Sys_error "Condition.create") in
|
|
{ mut = m; waiting = [] }
|
|
|
|
external sleep : unit -> unit = "caml_thread_sleep"
|
|
external wakeup : Thread.t -> unit = "caml_thread_wakeup"
|
|
|
|
let wait cond mut =
|
|
Mutex.lock cond.mut;
|
|
cond.waiting <- Thread.self() :: cond.waiting;
|
|
Mutex.unlock cond.mut;
|
|
Mutex.unlock mut;
|
|
sleep();
|
|
Mutex.lock mut
|
|
|
|
let signal cond =
|
|
Mutex.lock cond.mut;
|
|
match cond.waiting with
|
|
[] -> Mutex.unlock cond.mut
|
|
| th :: rem -> cond.waiting <- rem ; Mutex.unlock cond.mut; wakeup th
|
|
|
|
let broadcast cond =
|
|
Mutex.lock cond.mut;
|
|
let w = cond.waiting in
|
|
cond.waiting <- [];
|
|
Mutex.unlock cond.mut;
|
|
List.iter wakeup w
|
|
|
|
#else
|
|
|
|
type t
|
|
external create: unit -> t = "caml_condition_new"
|
|
external wait: t -> Mutex.t -> unit = "caml_condition_wait"
|
|
external signal: t -> unit = "caml_condition_signal"
|
|
external broadcast: t -> unit = "caml_condition_broadcast"
|
|
|
|
#endif
|