From 530507d84e07a9ad9718cbc77329dab0f72f0cf9 Mon Sep 17 00:00:00 2001 From: Simon Cruanes Date: Wed, 25 Oct 2023 22:11:08 -0400 Subject: [PATCH] fix fifo_pool: raise Shutdown, not Closed, in run --- src/fifo_pool.ml | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/fifo_pool.ml b/src/fifo_pool.ml index 54570bbb..920b36ed 100644 --- a/src/fifo_pool.ml +++ b/src/fifo_pool.ml @@ -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 (** 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 task' () =