cbaines/guile-knots
1
Fork 0
Code Issues Pull requests Activity Actions

Change how spawn-fiber-to-destroy-resource is used

Browse source 
And fix a couple of incorrect uses.
This commit is contained in:
Christopher Baines 2025-11-25 09:58:45 +00:00
parent 04d964a9f8
commit 9cce89fc01
1 changed files with 14 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

25
knots/resource-pool.scm
View file

@ -588,13 +588,11 @@
#:unwind? #t))))) #:unwind? #t)))))
#:unwind? #t)))) #:unwind? #t))))
(define (spawn-fiber-to-destroy-resource resource-id resource-details) (define (spawn-fiber-to-destroy-resource resource-id resource-value)
(spawn-fiber (spawn-fiber
(lambda () (lambda ()
(let loop () (let loop ()
(let* ((resource (let* ((success?
(resource-details-value resource-details))
(success?
(with-exception-handler (with-exception-handler
(lambda _ #f) (lambda _ #f)
(lambda () (lambda ()
@ -608,7 +606,7 @@
(print-backtrace-and-exception/knots exn) (print-backtrace-and-exception/knots exn)
(raise-exception exn)) (raise-exception exn))
(lambda () (lambda ()
(start-stack #t (destructor resource)) (start-stack #t (destructor resource-value))
#t))) #t)))
#:unwind? #t))) #:unwind? #t)))
@ -662,7 +660,8 @@
destructor) destructor)
(spawn-fiber-to-destroy-resource (spawn-fiber-to-destroy-resource
resource-id resource-id
(hash-ref resources resource-id))) (resource-details-value
(hash-ref resources resource-id))))
(hash-remove! resources resource-id) (hash-remove! resources resource-id)
@ -886,7 +885,8 @@
lifetime)) lifetime))
(begin (begin
(spawn-fiber-to-destroy-resource resource-id (spawn-fiber-to-destroy-resource resource-id
resource-details) (resource-details-value
resource-details))
(loop next-resource-id (loop next-resource-id
available available
waiters)) waiters))
@ -956,7 +956,8 @@
(hash-ref resources (hash-ref resources
resource-id))) resource-id)))
(spawn-fiber-to-destroy-resource resource-id (spawn-fiber-to-destroy-resource resource-id
resource-details) (resource-details-value
resource-details))
(loop next-resource-id (loop next-resource-id
available available
@ -1033,7 +1034,8 @@
(lambda (resource-id) (lambda (resource-id)
(spawn-fiber-to-destroy-resource (spawn-fiber-to-destroy-resource
resource-id resource-id
(hash-ref resources resource-id))) (resource-details-value
(hash-ref resources resource-id))))
resources-to-destroy)) resources-to-destroy))
(loop next-resource-id (loop next-resource-id
@ -1072,8 +1074,9 @@
(lambda (resource-id) (lambda (resource-id)
(spawn-fiber-to-destroy-resource (spawn-fiber-to-destroy-resource
resource-id resource-id
(hash-ref resources (resource-details-value
resource-id))) (hash-ref resources
resource-id))))
available)) available))
;; Do this in parallel to avoid deadlocks between the ;; Do this in parallel to avoid deadlocks between the