;;;; Example of using a mutex to synchronize summing of a variable by multiple threads.
(import (scheme base)
        (scheme read)
        (scheme write)
        (cyclone concurrent)
        (srfi 18))

(define m (make-mutex))

(define *sum* 0.0)

(define (sum-loop n)
  (mutex-lock! m)
  (set! *sum* (+ *sum* 1))
  (mutex-unlock! m)
  ;(swap! *sum* + 1)
  (if (zero? n)
      (display "thread done\n")
      (sum-loop (- n 1))))

(define (sum-entry-pt)
  (sum-loop (* 100 100 100)))

;; Thread - Do something, then let main thread know when we are done
(define t1 (make-thread sum-entry-pt))
(define t2 (make-thread sum-entry-pt))
(define t3 (make-thread sum-entry-pt))
(define t4 (make-thread sum-entry-pt))
(define t5 (make-thread sum-entry-pt))
(define t6 (make-thread sum-entry-pt))
(define t7 (make-thread sum-entry-pt))
(define t8 (make-thread sum-entry-pt))
(define t9 (make-thread sum-entry-pt))
(thread-start! t1)
(thread-start! t2)
(thread-start! t3)
(thread-start! t4)
(thread-start! t5)
(thread-start! t6)
(thread-start! t7)
(thread-start! t8)
(thread-start! t9)

(thread-join! t1)
(thread-join! t2)
(thread-join! t3)
(thread-join! t4)
(thread-join! t5)
(thread-join! t6)
(thread-join! t7)
(thread-join! t8)
(thread-join! t9)
(display "main thread done, sum = ")
(mutex-lock! m)
(display *sum*)
(newline)
(mutex-unlock! m)