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

db: use channel instead of semaphore + result variable

Browse Source
This commit is contained in:
Ryan Culpepper 2012-08-25 17:14:56 -04:00
parent 01e19983da
commit 8363db9258
1 changed files with 9 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
collects/db/private/generic/connect-util.rkt
View File

@ -38,20 +38,18 @@
(define/private (call* proc chan as-evt?)
(thread-resume mthread (current-thread))
(let* ([result #f]
[sema (make-semaphore 0)]
(let* ([return-channel (make-channel)]
[proc (lambda ()
(set! result
(with-handlers ([(lambda (e) #t)
(lambda (e) (cons 'exn e))])
(cons 'values (call-with-values proc list))))
(semaphore-post sema))]
(channel-put return-channel
(with-handlers ([(lambda (e) #t)
(lambda (e) (cons 'exn e))])
(cons 'values (call-with-values proc list)))))]
[handler
(lambda (_evt)
(semaphore-wait sema)
(case (car result)
((values) (apply values (cdr result)))
((exn) (raise (cdr result)))))])
(let ([result (channel-get return-channel)])
(case (car result)
((values) (apply values (cdr result)))
((exn) (raise (cdr result))))))])
(if as-evt?
(wrap-evt (channel-put-evt chan proc) handler)
(begin (channel-put chan proc)