CODEWITHSUNDEEP
clojuretiming
Hendekagon
Hendekagon

Reputation: 4643

Executing code at regularly timed intervals in Clojure

What's the best way to make code run at regular intervals in Clojure ? I'm currently using java.util.concurrent.ScheduledExecutorService, but that's Java - is there a Clojure way of scheduling code to run at regular intervals, after a delay, cancellably ? All the Clojure code examples I've seen use Thread/sleep, which also seems too Java.

Upvotes: 19

Views: 4655

Answers (4)

Dmitry
Dmitry

Reputation: 2993

The "tools.timer" library is a Java Timer wrapper: https://github.com/Ruiyun/tools.timer

It is very easy to use:

(use 'ruiyun.tools.timer)
(run-task! #(println "Say hello every 5 seconds.") :period 5000)

Upvotes: 0

zcaudate
zcaudate

Reputation: 14258

I answered my own question @ Implementing a cron type scheduler in clojure

maybe cronj might help?

Upvotes: 1

mikera
mikera

Reputation: 106351

Well worth looking at the source code for Overtone, in particular the code for scheduling events at a particular time.

It's a music synthesis system so you have to hope they have the timing code right!!

Also they have helpfully separated the timing code out into a separate project (overtone/at-at) so that you can easily import it if you want. This provides a nice Clojure wrapper to the underlying Java libraries (i.e. ScheduledThreadPoolExecutor and friends). The syntax is like this:

;; run some-function every 500ms
(every 500 some-function)

You can also shedule events at specific times:

;; run some-other-function 10 seconds from now
(at (+ 10000 (now)) some-other-function)

Upvotes: 22

nickmbailey
nickmbailey

Reputation: 3684

From the clojure website http://clojure.org/concurrent_programming:

In all cases, Clojure does not replace the Java thread system, rather it works with it. Clojure functions are java.util.concurrent.Callable, therefore they work with the Executor framework etc.

It sounds like you are already doing it the right way.

(import 'java.util.concurrent.Executors)
(import 'java.util.concurrent.TimeUnit) 
(.scheduleAtFixedRate (Executors/newScheduledThreadPool 1) 
  #(println "Hello") 0 5 TimeUnit/SECONDS)

Upvotes: 20

Related Questions