simon/moonpool
1
0
Fork 0
mirror of https://github.com/c-cube/moonpool.git synced 2025-12-06 03:05:30 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix fifo_pool: raise Shutdown, not Closed, in run

Browse source
This commit is contained in:
Simon Cruanes 2023-10-25 22:11:08 -04:00
parent 3f720241b2
commit 530507d84e
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
1 changed files with 2 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
src/fifo_pool.ml
View file

@ -12,7 +12,8 @@ let[@inline] size_ (self : state) = Array.length self.threads
let[@inline] num_tasks_ (self : state) : int = Bb_queue.size self.q let[@inline] num_tasks_ (self : state) : int = Bb_queue.size self.q
(** Run [task] as is, on the pool. *) (** Run [task] as is, on the pool. *)
let run_direct_ (self : state) (task : task) : unit = Bb_queue.push self.q task let run_direct_ (self : state) (task : task) : unit =
try Bb_queue.push self.q task with Bb_queue.Closed -> raise Shutdown
let rec run_async_ (self : state) (task : task) : unit = let rec run_async_ (self : state) (task : task) : unit =
let task' () = let task' () =