async.processes.clj

(ns async.example
  (:require [clojure.core.async :refer (chan go-loop <! >!)])
  (:import [java.util Date])
  (:gen-class))

(defn producer-process [channel]
  (go-loop []
    (>! channel (str "Hello, the time is " (Date.)))
    (Thread/sleep 500)
    (recur)))

(defn consumer-process [channel]
  (go-loop [message (<! channel)]
    (println "Received:" message)
    (recur (<! channel))))



(defn wait! []
  (let [s (java.util.concurrent.Semaphore. 0)]
    (.acquire s)))

(defn -main [& args]
  (let [c (chan)]
    (producer-process c)
    (consumer-process c)
    (wait!)))