simon/ocaml-containers
1
0
Fork 0
mirror of https://github.com/c-cube/ocaml-containers.git synced 2025-12-06 11:15:31 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

small fixes in CCSemaphore

Browse source
This commit is contained in:
Simon Cruanes 2016-01-25 14:26:30 +01:00
parent d3464563c1
commit 483f90cb52
2 changed files with 8 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
src/threads/CCSemaphore.ml
View file

@ -6,11 +6,12 @@ type t = {
cond : Condition.t; cond : Condition.t;
} }
let create n = { let create n =
n; if n <= 0 then invalid_arg "Semaphore.create";
mutex=Mutex.create(); { n;
cond=Condition.create(); mutex=Mutex.create();
} cond=Condition.create();
}
let get t = t.n let get t = t.n

4
src/threads/CCSemaphore.mli
View file

@ -9,13 +9,13 @@ type t
val create : int -> t val create : int -> t
(** [create n] creates a semaphore with initial value [n] (** [create n] creates a semaphore with initial value [n]
@raise Invalid_argument if [n < 0] *) @raise Invalid_argument if [n <= 0] *)
val get : t -> int val get : t -> int
(** Current value *) (** Current value *)
val acquire : int -> t -> unit val acquire : int -> t -> unit
(** [acquire n s] blocks until [get s > n], then atomically (** [acquire n s] blocks until [get s >= n], then atomically
sets [s := !s - n] *) sets [s := !s - n] *)
val release : int -> t -> unit val release : int -> t -> unit