mirror of
https://github.com/c-cube/moonpool.git
synced 2025-12-06 03:05:30 -05:00
update tests
This commit is contained in:
parent
c39435d8eb
commit
22f43670a7
2 changed files with 1943 additions and 3 deletions
File diff suppressed because it is too large
Load diff
|
|
@ -95,7 +95,7 @@ module Render = struct
|
|||
List.iter (pp_tree 2 oc) self.roots
|
||||
end
|
||||
|
||||
let () =
|
||||
let run ~pool ~pool_name () =
|
||||
let tracer = Tracer.create () in
|
||||
|
||||
let sub_sub_child ~idx ~idx_child ~idx_sub ~idx_sub_sub () =
|
||||
|
|
@ -155,8 +155,7 @@ let () =
|
|||
List.iter F.await subs
|
||||
in
|
||||
|
||||
let@ pool = Ws_pool.with_ () in
|
||||
|
||||
Printf.printf "run test on pool = %s\n" pool_name;
|
||||
let fibs =
|
||||
List.init 8 (fun idx -> F.spawn_top ~on:pool (fun () -> top idx))
|
||||
in
|
||||
|
|
@ -168,3 +167,11 @@ let () =
|
|||
Render.pp stdout tree;
|
||||
Printf.printf "done\n%!";
|
||||
()
|
||||
|
||||
let () =
|
||||
(let@ pool = Ws_pool.with_ () in
|
||||
run ~pool ~pool_name:"ws_pool" ());
|
||||
|
||||
(let@ pool = Fifo_pool.with_ () in
|
||||
run ~pool ~pool_name:"ws_pool" ());
|
||||
()
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue