123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115 |
- (define-module (ice-9 serialize)
- :use-module (ice-9 threads)
- :export (call-with-serialization
- call-with-parallelization)
- :export-syntax (serialize
- parallelize))
- (define serialization-mutex (make-mutex))
- (define admin-mutex (make-mutex))
- (define owner #f)
- (define (call-with-serialization thunk)
- (let ((outer-owner #f))
- (dynamic-wind
- (lambda ()
- (lock-mutex admin-mutex)
- (set! outer-owner owner)
- (if (not (eqv? outer-owner (current-thread)))
- (begin
- (unlock-mutex admin-mutex)
- (lock-mutex serialization-mutex)
- (set! owner (current-thread)))
- (unlock-mutex admin-mutex)))
- thunk
- (lambda ()
- (lock-mutex admin-mutex)
- (if (not (eqv? outer-owner (current-thread)))
- (begin
- (set! owner #f)
- (unlock-mutex serialization-mutex)))
- (unlock-mutex admin-mutex)))))
- (define-macro (serialize . forms)
- `(call-with-serialization (lambda () ,@forms)))
- (define (call-with-parallelization thunk)
- (let ((outer-owner #f))
- (dynamic-wind
- (lambda ()
- (lock-mutex admin-mutex)
- (set! outer-owner owner)
- (if (eqv? outer-owner (current-thread))
- (begin
- (set! owner #f)
- (unlock-mutex serialization-mutex)))
- (unlock-mutex admin-mutex))
- thunk
- (lambda ()
- (lock-mutex admin-mutex)
- (if (eqv? outer-owner (current-thread))
- (begin
- (unlock-mutex admin-mutex)
- (lock-mutex serialization-mutex)
- (set! owner outer-owner))
- (unlock-mutex admin-mutex))))))
- (define-macro (parallelize . forms)
- `(call-with-parallelization (lambda () ,@forms)))
|