This commit is contained in:
parent
b6746fffde
commit
f38456b4c6
1 changed files with 15 additions and 0 deletions
|
|
@ -28,6 +28,7 @@
|
||||||
#:export (fibers-promise?
|
#:export (fibers-promise?
|
||||||
|
|
||||||
fibers-delay
|
fibers-delay
|
||||||
|
fibers-delay/eager
|
||||||
fibers-force
|
fibers-force
|
||||||
fibers-promise-reset
|
fibers-promise-reset
|
||||||
fibers-promise-result-available?))
|
fibers-promise-result-available?))
|
||||||
|
|
@ -105,6 +106,20 @@
|
||||||
(raise-exception res)
|
(raise-exception res)
|
||||||
(apply values res))))))
|
(apply values res))))))
|
||||||
|
|
||||||
|
|
||||||
|
(define (fibers-delay/eager thunk)
|
||||||
|
(let ((promise (fibers-delay thunk)))
|
||||||
|
(spawn-fiber
|
||||||
|
(lambda ()
|
||||||
|
(with-exception-handler
|
||||||
|
(lambda _
|
||||||
|
;; Silently handle this exception
|
||||||
|
#f)
|
||||||
|
(lambda ()
|
||||||
|
(fibers-force promise))
|
||||||
|
#:unwind? #t)))
|
||||||
|
promise))
|
||||||
|
|
||||||
(define (fibers-promise-reset fp)
|
(define (fibers-promise-reset fp)
|
||||||
(atomic-box-set! (fibers-promise-values-box fp)
|
(atomic-box-set! (fibers-promise-values-box fp)
|
||||||
#f))
|
#f))
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue