Performance counter for Clojure (using core.async)

Question

I am wondering what is the best way to implement performance counters in Clojure for a particular task that runs concurrently.

I usually end up having something like this:

(defn -main [& args]
  (let [c (async/chan)]
    (doseq [_ (range 50)]
      (async/thread
        (async/>!! c

              (doseq [r (chunk-of-work)]
                (println r)
                (doall (pmap #(work %) r))))

        )
      )
    )

 (while true
      (async/<!! c))
  )
)

What would be the best way of counting how many messages I am getting through the channel every second? The code is indented for better readability.

Mark Fisher · Accepted Answer · 2014-11-10 18:03:50Z

1

Have you considered ztellman's Narrator. It's a package for

"analyzing and aggregating streams of data"

There's plenty of examples, including one for the rate of messages over a period.

I haven't actually used it, just remembered reading its docs and it having this kind of aggregation build in.

answered Nov 10, 2014 at 18:03

Mark Fisher

9,9063 gold badges34 silver badges41 bronze badges

Sign up to request clarification or add additional context in comments.

Collectives™ on Stack Overflow

Performance counter for Clojure (using core.async)

1 Answer 1

Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

Comments

Your Answer

Sign up or log in

Post as a guest

Related