suzanne.soy/racket
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

cs & threads: fix plumber flushing interleaved with addition

Browse Source 
A plumber is supposed to gather all callbacks before running any of
them so that callbacks added by a callback are not run.
This commit is contained in:
Matthew Flatt 2019-05-18 11:05:16 -04:00
parent 7f92443a5f
commit 2c16beb942
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
racket/src/thread/plumber.rkt
View File

@ -43,10 +43,14 @@
(plumber-flush-all/wrap p (lambda (proc h) (proc h))))
(define (plumber-flush-all/wrap p app)
(for ([(h proc) (in-hash (plumber-callbacks p))])
(app proc h))
(for ([(h proc) (in-hash (plumber-weak-callbacks p))])
(app proc h)))
;; Spec requires getting all callbacks before running any
(define procs+hs
(for*/list ([cbs (in-list (list (plumber-callbacks p)
(plumber-weak-callbacks p)))]
[(h proc) (in-hash cbs)])
(cons proc h)))
(for ([proc+h (in-list procs+hs)])
(app (car proc+h) (cdr proc+h))))
(define/who (plumber-flush-handle-remove! h)
(check who plumber-flush-handle? h)