mirror of
https://github.com/c-cube/moonpool.git
synced 2025-12-06 03:05:30 -05:00
fix: uniformize domain stub
This commit is contained in:
parent
22ab8e4a69
commit
a585cc8158
2 changed files with 2 additions and 2 deletions
|
|
@ -53,7 +53,7 @@ type t = Thread.t
|
||||||
|
|
||||||
let get_id (self:t) : int = Thread.id self
|
let get_id (self:t) : int = Thread.id self
|
||||||
|
|
||||||
let spawn_on f : t =
|
let spawn f : t =
|
||||||
Thread.create f ()
|
Thread.create f ()
|
||||||
|}
|
|}
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -59,7 +59,7 @@ module D_pool_ = struct
|
||||||
(let n = Domain_.recommended_number () in
|
(let n = Domain_.recommended_number () in
|
||||||
Array.init n (fun i ->
|
Array.init n (fun i ->
|
||||||
let q = S_queue.create () in
|
let q = S_queue.create () in
|
||||||
let _domain : domain = Domain_.spawn_on (fun () -> work_ i q) in
|
let _domain : domain = Domain_.spawn (fun () -> work_ i q) in
|
||||||
{ q }))
|
{ q }))
|
||||||
|
|
||||||
(** Number of domains in the pool *)
|
(** Number of domains in the pool *)
|
||||||
|
|
|
||||||
Loading…
Add table
Reference in a new issue