package eio

  1. Overview
  2. Docs
Effect-based direct-style IO API for OCaml

Install

dune-project
 Dependency

Authors

Maintainers

Sources

eio-1.3.tbz
sha256=8ed5c13e6689f31c85dca5f12762d84b8cc0042a7b07d3e464df6eb4b72b3dfc
sha512=46e8f817f32c3316e7f35835a136ad177a295b3306351eb2efa2386482b0169a5b19ed2925b32da2a1f10d40f083fe3d588dd401908f9fec6e4a44cd68535204

doc/src/eio.utils/zzz.ml.html

Source file zzz.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
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
module Key = struct
  type t = Optint.Int63.t
  let compare = Optint.Int63.compare
end

type item =
  | Fiber of unit Suspended.t
  | Fn of (unit -> unit)

module Job = struct
  type t = {
    time : Mtime.t;
    item : item;
  }

  let compare a b = Mtime.compare a.time b.time
end

module Q = Psq.Make(Key)(Job)

type t = {
  mutable sleep_queue: Q.t;
  mutable next_id : Optint.Int63.t;
}

let create () = { sleep_queue = Q.empty; next_id = Optint.Int63.zero }

let add t time item =
  let id = t.next_id in
  t.next_id <- Optint.Int63.succ t.next_id;
  let sleeper = { Job.time; item } in
  t.sleep_queue <- Q.add id sleeper t.sleep_queue;
  id

let remove t id =
  t.sleep_queue <- Q.remove id t.sleep_queue

let pop t ~now =
  match Q.min t.sleep_queue with
  | Some (_, { Job.time; item }) when time <= now ->
    begin
      match item with
      | Fiber k -> Eio.Private.Fiber_context.clear_cancel_fn k.fiber
      | Fn _ -> ()
    end;
    t.sleep_queue <- Option.get (Q.rest t.sleep_queue);
    `Due item
  | Some (_, { Job.time; _ }) -> `Wait_until time
  | None -> `Nothing
OCaml

Innovation. Community. Security.