Source file OLinq_map.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
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209

(* This file is free software, part of OLinq. See file "license" for more details. *)

(** {1 Polymorphic Maps and Multimaps} *)

type 'a equal = 'a -> 'a -> bool
type 'a ord = 'a -> 'a -> int
type 'a hash = 'a -> int
type 'a iter = ('a -> unit) -> unit

type ('a, +'b) t = {
  is_empty : unit -> bool;
  size : unit -> int; (* Number of keys *)
  get_exn : 'a -> 'b;
  iter : ('a -> 'b -> unit) -> unit;
  fold : 'c. ('c -> 'a -> 'b -> 'c) -> 'c -> 'c;
  choose: (unit -> ('a * 'b) option);
}

type ('a, +'b) map = ('a, 'b) t

let get_exn m x = m.get_exn x

let get m x =
  try Some (m.get_exn x)
  with Not_found -> None

let mem m x =
  try ignore (m.get_exn x); true
  with Not_found -> false

let to_iter m yield = m.iter (fun k v -> yield (k,v))

let to_iter_multimap m yield =
  m.iter (fun k vs -> List.iter (fun v -> yield (k,v)) vs)

let get_seq key m yield = match get m key with
  | None -> ()
  | Some x -> yield x

let iter m = m.iter

let fold f acc m = m.fold f acc

let fold_multimap f acc m =
  m.fold (fun acc x l -> List.fold_left (fun acc y -> f acc x y) acc l) acc

let size m = m.size ()

module Build = struct
  type ('a, 'b) t = {
    cur : unit -> ('a, 'b) map;
    add : 'a -> 'b -> unit;
    update : 'a -> f:('b -> 'b) -> or_:'b -> unit;
  }

  let get b = b.cur ()
  let add b x y = b.add x y
  let update b f = b.update f

  let add_multimap b x y = update b x ~f:(fun l -> y::l) ~or_:[y]

  let add_count b x = update b x ~f:succ ~or_:1

  (* careful to use this map linearly *)
  let of_hash (type key) ?(eq=(=)) ?(hash=Hashtbl.hash) ?(size=128) () =
    let module H = Hashtbl.Make(struct
        type t = key
        let equal = eq
        let hash = hash
      end) in
    (* build table *)
    let tbl = H.create size in
    let cur () = {
      is_empty = (fun () -> H.length tbl = 0);
      size = (fun () -> H.length tbl);
      get_exn = (fun k -> H.find tbl k);
      fold = (fun f acc -> H.fold (fun k v acc -> f acc k v) tbl acc);
      iter = (fun k -> H.iter (fun key v -> k key v) tbl);
      choose = (fun () ->
        let r = ref None in
        (try H.iter (fun k v -> r := Some (k,v); raise Exit) tbl with Exit -> ());
        !r);
    } in
    { cur;
      add = (fun k v -> H.replace tbl k v);
      update =
        (fun k ~f ~or_ ->
          try
            let v = f (H.find tbl k) in
            H.replace tbl k v
          with Not_found -> H.add tbl k or_);
    }

  let of_cmp (type key) ?(cmp=Pervasives.compare) () =
    let module M = Map.Make(struct
        type t = key
        let compare = cmp
      end) in
    let of_map map = {
      is_empty = (fun () -> M.is_empty map);
      size = (
        let size = lazy (M.cardinal map) in
        fun () -> Lazy.force size);
      get_exn = (fun k -> M.find k map);
      fold =
        (fun f acc ->
          M.fold
            (fun key set acc -> f acc key set) map acc);
      iter = (fun k -> M.iter k map);
      choose = (fun () -> try Some (M.choose map) with Not_found -> None);
    } in
    let map = ref M.empty in
    let cur () = of_map !map in
    {
      cur;
      add = (fun k v -> map := M.add k v !map);
      update =
        (fun k ~f ~or_ ->
          try
            let v = f (M.find k !map) in
            map := M.add k v !map
          with Not_found ->
            map := M.add k or_ !map);
    }

  type 'a src =
    | Cmp of 'a ord
    | Hash of 'a equal * 'a hash * int
    | Default

  let of_src = function
    | Default -> of_hash ()
    | Cmp cmp -> of_cmp ~cmp ()
    | Hash (eq,hash,size) -> of_hash ~eq ~hash ~size ()

  (* choose a build method from the optional arguments *)
  let src_of_args ?cmp ?eq ?hash () =
    let _maybe default o = match o with
      | Some x -> x
      | None -> default
    in
    match eq, hash with
    | Some _, _
    | _, Some _ ->
        Hash ( _maybe (=) eq, _maybe Hashtbl.hash hash, 128)
    | _ ->
        match cmp with
        | Some f -> Cmp f
        | _ -> Default

  let make ?cmp ?eq ?hash () =
    let src = src_of_args ?cmp ?eq ?hash () in
    of_src src
end

let of_iter ?(src=Build.Default) seq =
  let build = Build.of_src src in
  seq (fun (k,v) -> Build.add_multimap build k v);
  Build.get build

let of_list ?(src=Build.Default) l =
  let build = Build.of_src src in
  List.iter (fun (k,v) -> Build.add_multimap build k v) l;
  Build.get build

let count_seq ?(src=Build.Default) seq =
  let build = Build.of_src src in
  seq (fun x -> Build.add_count build x);
  Build.get build

(* map values *)
let map f m = {
  is_empty = m.is_empty;
  size = m.size;
  get_exn = (fun k -> f (m.get_exn k));
  iter = (fun k -> m.iter (fun x y -> k x (f y)));
  fold = (fun f' acc ->
      m.fold (fun acc x y -> f' acc x (f y)) acc
    );
  choose = (fun () ->
    match m.choose () with None -> None | Some (k,v) -> Some (k, f v)
  );
}

let choose m = m.choose()

let to_rev_list m = m.fold (fun acc k v -> (k,v) :: acc) []

let to_list m = List.rev (to_rev_list m)

let reverse ?(src=Build.Default) m =
  let build = Build.of_src src in
  m.iter (fun k v -> Build.add_multimap build v k);
  Build.get build

let reverse_multimap ?(src=Build.Default) m =
  let build = Build.of_src src in
  m.iter
    (fun k vs ->
      List.iter
        (fun v -> Build.add_multimap build v k)
        vs);
  Build.get build

let flatten m yield =
  m.iter (fun k vs -> vs (fun v -> yield (k,v)))

let flatten_l = to_iter_multimap