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

more benchs

Browse source
This commit is contained in:
Simon Cruanes 2016-01-26 01:45:14 +01:00
parent a3e4ab5cc9
commit f95825a2e5
1 changed files with 18 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
benchs/run_benchs.ml
View file

@ -1036,6 +1036,23 @@ module Thread = struct
; "pool", fib_pool_ ~size, n
]
let bench_sequence ~size n =
let module P = CCPool.Make(struct let max_size = size end) in
let id_ x = Thread.delay 0.0001; x in
let mk_list() = CCList.init n (P.Fut.make1 id_) in
let mk_sequence () =
let l = mk_list() in
P.Fut.sequence_l l |> P.Fut.get
(* reserves a thread for the computation *)
and mk_blocking () =
let l = mk_list() in
P.Fut.make (fun () -> List.map P.Fut.get l) |> P.Fut.get
in
B.throughputN 3 ~repeat
[ "sequence", mk_sequence, ()
; "blocking", mk_blocking, ()
]
let () = B.Tree.register (
let take_push = CCList.map
(fun (size,senders,receivers) ->
@ -1057,6 +1074,7 @@ module Thread = struct
( take_push @
[ "fib_size5" @>> app_ints (bench_pool ~size:5) [10; 15; 30; 35]
; "fib_size15" @>> app_ints (bench_pool ~size:15) [10; 15; 30; 35]
; "sequence" @>> app_ints (bench_sequence ~size:15) [100; 500; 10_000; 100_000]
]
)
)