From e1d9ec6fc512f93339ebd8c996adfbd7eabd5f48 Mon Sep 17 00:00:00 2001 From: haskal Date: Sun, 3 May 2020 00:19:19 -0400 Subject: [PATCH] oops --- private/taskq.rkt | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/private/taskq.rkt b/private/taskq.rkt index 883e4bb..cf208b0 100644 --- a/private/taskq.rkt +++ b/private/taskq.rkt @@ -90,7 +90,8 @@ (for ([w (in-set dequeue-waiters)]) (thread-send w #f #f)) (for ([(k v) (in-hash task-waiters)]) - (thread-send v (error "queue shutdown") #f))) + (for ([w (in-set v)]) + (thread-send w (error "queue shutdown") #f)))) ;; attempts to dequeue the next work ;; if there is work, set it to executing and invoke and remove one of the workers