demonstration of concurrency in 8sync

actress.scm

(use-modules (oop goops)
             (8sync)
             (ice-9 atomic))

(define-actor <actress> (<actor>)
  ((recv actress-recv)))

(define (actress-recv actress message)
  (8sleep 1)
  (format #t "received message at ~a\n" (strftime "%c" (localtime (current-time)))))

(define-actor <directress> (<actor>)
  ((direct directress-direct))
  (actress #:init-keyword #:actress
           #:accessor directress-actress))

(define (directress-direct directress message count)
  (define actress (directress-actress directress))
  (format #t "directing\n")
  (let loop ((i 0))
    (cond ((eq? i count)
           #t)
          (else
           (<- actress 'recv)
           (loop (+ i 1)))))
  (8sleep (+ count 1))
  (format #t "directed\n"))

(let* ((hive (make-hive))
       (actress (bootstrap-actor hive <actress>))
       (directress (bootstrap-actor hive <directress>
                                    #:actress actress)))
  (run-hive hive (list (bootstrap-message hive directress 'direct 10))))

;; output
;; directing
;; received message at Tue 03 Mar 2020 06:11:09 PM EST
;; received message at Tue 03 Mar 2020 06:11:09 PM EST
;; received message at Tue 03 Mar 2020 06:11:09 PM EST
;; received message at Tue 03 Mar 2020 06:11:09 PM EST
;; received message at Tue 03 Mar 2020 06:11:09 PM EST
;; received message at Tue 03 Mar 2020 06:11:09 PM EST
;; received message at Tue 03 Mar 2020 06:11:09 PM EST
;; received message at Tue 03 Mar 2020 06:11:09 PM EST
;; received message at Tue 03 Mar 2020 06:11:09 PM EST
;; received message at Tue 03 Mar 2020 06:11:09 PM EST
;; directed