package devkit

  1. Overview
  2. Docs
Development kit - general purpose library

Install 

dune-project
 Dependency

github.com Readme Edit opam file Versions (9)

Authors

  1. A
    Ahrefs <github@ahrefs.com>

Maintainers

  1. I
    igor@ahrefs.com

Sources

1.20261006.tar.gz
md5=a39dbbce04bd5562a9b4443daf39c582
sha512=b10104b61384b2151521b785e7f3c3250134c75eae09b42cad69bc4a22a9a5e429beb891ee87cedf376c23d9c40f09d3f71c3fd48aa35df490c0f69dc17f3242

doc/src/devkit.core/mtq.ml.html

Source file mtq.ml

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

(* ExtThread.locked, duplicated to break internal circular dependency in ExtThread *)
let locked mutex f = Mutex.lock mutex; Std.finally (fun () -> Mutex.unlock mutex) f ()

type 'a t = { mutex : Mutex.t; cond : Condition.t; q : 'a Queue.t; }

let create () = { mutex = Mutex.create (); cond = Condition.create (); q = Queue.create (); }

let put q v = locked q.mutex (fun () -> Queue.push v q.q; Condition.signal q.cond)

let get q = locked q.mutex (fun () ->
  while Queue.is_empty q.q do Condition.wait q.cond q.mutex done;
  Queue.pop q.q)

let peek q = locked q.mutex (fun () ->
  while Queue.is_empty q.q do Condition.wait q.cond q.mutex done;
  Queue.peek q.q)

let junk q = locked q.mutex (fun () ->
  let _ = Exn.catch Queue.pop q.q in ())

let try_get q = locked q.mutex (fun () -> Exn.catch Queue.pop q.q)

let length q = locked q.mutex (fun () -> Queue.length q.q)

let clear q = locked q.mutex (fun () -> Queue.clear q.q)