mirror of
https://github.com/justinethier/cyclone.git
synced 2025-05-18 21:29:18 +02:00
57 lines
1.3 KiB
Scheme
57 lines
1.3 KiB
Scheme
;;;; 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)
|