blob: b0c9d21a2e0e6699f1a03a279d6d18f4246f937b (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
|
(***********************************************************************)
(* *)
(* Objective Caml *)
(* *)
(* Xavier Leroy and Damien Doligez, INRIA Rocquencourt *)
(* *)
(* Copyright 1996 Institut National de Recherche en Informatique et *)
(* Automatique. Distributed only by permission. *)
(* *)
(***********************************************************************)
(* $Id$ *)
type t = { mutable waiting: Thread.t list }
let create () = { waiting = [] }
let wait cond mut =
Thread.critical_section := true;
Mutex.unlock mut;
cond.waiting <- Thread.self() :: cond.waiting;
Thread.sleep();
Mutex.lock mut
let signal cond =
match cond.waiting with (* atomic *)
[] -> ()
| th :: rem -> cond.waiting <- rem (* atomic *); Thread.wakeup th
let broadcast cond =
let w = cond.waiting in (* atomic *)
cond.waiting <- []; (* atomic *)
List.iter Thread.wakeup w
|
