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

cs & thread: simplificaton for future "sync" action

Browse Source
This commit is contained in:
Matthew Flatt 2019-10-09 15:52:34 -06:00
parent 7cc3345761
commit f3aae7f4fb
1 changed files with 11 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
racket/src/thread/future.rkt
View File

@ -369,20 +369,17 @@
[else
;; In case the main thread is trying to shut down futures, check in:
(engine-block)
;; Atomic mode prevents getting terminated or swapped out
;; while we block on the main thread
(current-atomic (add1 (current-atomic)))
(begin0
;; Host's `call-as-asynchronous-callback` will post `thunk`
;; so that it's returned by `host:poll-async-callbacks` to
;; the scheduler in the place's main thread
(host:call-as-asynchronous-callback
(lambda ()
(log-future 'sync (future*-id me-f) #:prim-name who)
(let ([v (thunk)])
(log-future 'result (future*-id me-f))
v)))
(current-atomic (sub1 (current-atomic))))]))
;; Host's `call-as-asynchronous-callback` will post `thunk`
;; so that it's returned by `host:poll-async-callbacks` to
;; the scheduler in the place's main thread; it will also
;; tell the scheduler to be in atomic mode so that we don't
;; get terminated or swapped out while blocking on the main thread
(host:call-as-asynchronous-callback
(lambda ()
(log-future 'sync (future*-id me-f) #:prim-name who)
(let ([v (thunk)])
(log-future 'result (future*-id me-f))
v)))]))
;; ----------------------------------------