2019-12-02 02:47:22 +00:00
|
|
|
(defn worker-main
|
|
|
|
[parent]
|
2019-12-02 10:39:13 +00:00
|
|
|
(def name (:receive parent))
|
|
|
|
(def interval (:receive parent))
|
2019-12-02 02:47:22 +00:00
|
|
|
(for i 0 10
|
2019-12-02 10:39:13 +00:00
|
|
|
(os/sleep interval)
|
|
|
|
(printf "thread %s wakeup no. %d\n" name i))
|
|
|
|
(:send parent :done))
|
2019-12-02 02:47:22 +00:00
|
|
|
|
|
|
|
(defn make-worker
|
2019-12-02 10:39:13 +00:00
|
|
|
[name interval]
|
|
|
|
(-> (thread/new)
|
|
|
|
(:send worker-main)
|
|
|
|
(:send name)
|
|
|
|
(:send interval)))
|
2019-12-02 02:47:22 +00:00
|
|
|
|
2019-12-02 10:39:13 +00:00
|
|
|
(def bob (make-worker "bob" 0.2))
|
|
|
|
(def joe (make-worker "joe" 0.3))
|
|
|
|
(def sam (make-worker "joe" 0.5))
|
2019-12-02 02:47:22 +00:00
|
|
|
|
2019-12-02 10:39:13 +00:00
|
|
|
# Receive out of order
|
|
|
|
(:receive bob)
|
|
|
|
(:receive sam)
|
|
|
|
(:receive joe)
|