matchable
srfi-18 ; threads
srfi-69 ; hashtable
- udp6
- uri-generic)
+ udp
+ fifo)
;; Actors
(define (deliver-message address . message)
(let ((id (address-id address)))
- (let ((behaviour (hash-table-ref/default actor-table id '()))))
- (if (null? behaviour)
- (print "Warning: discarded message" message " to unknown actor " address)
- (match (apply (hash-table-ref actor-table id) (cons address message))
- ('done (hash-table-delete! actor-table actor))
- ('sleep 'do-nothing)
- (new-beh (hash-table-put! actor new-beh))))))
+ (let ((behaviour (hash-table-ref/default actor-table id '())))
+ (if (null? behaviour)
+ (print "Warning: discarded message" message " to unknown actor " address)
+ (match (apply (hash-table-ref actor-table id) (cons address message))
+ ('done (hash-table-delete! actor-table actor))
+ ('sleep 'do-nothing)
+ (new-beh (hash-table-put! actor new-beh)))))))
;; Scheduler
(define local-queue-mutex (make-mutex "message queue"))
(define message-available-mutex (make-mutex "message available"))
+(mutex-lock! message-available-mutex #f #f)
(define local-queue (make-fifo))
(define (send-message address . message)
(define (send-local-message address . message)
(mutex-lock! local-queue-mutex)
(fifo-push local-queue (cons address message))
+ (mutex-unlock! message-available-mutex)
(mutex-unlock! local-queue-mutex))
(define (send-network-message address . message)
(define (next-local-message)
(let ((res #f))
+ (mutex-lock! message-available-mutex)
(mutex-lock! local-queue-mutex)
- (set! res (if (fifo-empty? local-queue)
- #f
- (fifo-pop local-queue)))
+ (set! res (fifo-pop local-queue))
+ (mutex-unlock! message-available-mutex)
(mutex-unlock! local-queue-mutex)
res))
(make-thread
(lambda ()
(let loop ((next-addressed-message (next-local-message)))
- (if next-addressed-message
- (apply deliver-message next-addressed-message)
- (begin
- (lo))))))
+ (apply deliver-message next-addressed-message)
+ (loop (next-local-message))))))
- (thread-start!))
+(thread-start! scheduler-thread)
+
+(thread-join! scheduler-thread)