runp! runs a given function on a given collection in parallel.

runp-timeout.clj

(defn runp!
    "Runs the function `f` in parallel on the given collection `coll`.
        It will use (by default) the same numbers of threads as there are cores available on the system.
        You can set a specific number of threads using `:threads` waits maximum `:timeout` milliseconds."
    ([f coll {:keys [threads timeout] :or {threads (.availableProcessors (Runtime/getRuntime))}}]
        (let [pool (java.util.concurrent.Executors/newFixedThreadPool threads)
              tasks (map (fn [e] (fn [] (f e))) coll)]
        (try
            (doseq [future (.invokeAll pool tasks)]
                (.get future))
            (catch InterruptedException e
                (.shutdownNow pool))
            (finally
                (.shutdown pool)
                (when timeout
                    (when-not (.awaitTermination pool timeout java.util.concurrent.TimeUnit/MILLISECONDS)
                        (.shutdownNow pool))))))))

runp.clj

(defn runp!
    "Runs the function `f` in parallel on the given collection `coll`.
        It will use (by default) the same numbers of threads as there are cores available on the system.
        You can set a specific number of threads using `:threads`."
    ([f coll]
        (runp! f coll (.availableProcessors (Runtime/getRuntime))))
    ([f coll threads]
        (let [pool (java.util.concurrent.Executors/newFixedThreadPool threads)
              tasks (map (fn [e] (fn [] (f e))) coll)]
        (try
            (doseq [future (.invokeAll pool tasks)]
                (.get future))
            (finally
                (.shutdown pool))))))