facility_lms.clj

(defn pmap+
  "
  Like pmap but accepts a custom size of a parallel
  window. Not lazy, returns a vector. Takes only
  one collection of arguments at the moment.
  "
  [n func items]
  (lazy-seq
   (let [[head tail]
         (split-at n items)]
     (when (seq head)
       (let [futures
             (for [item head]
               (future (func item)))]
         (concat
          (->> futures
               doall
               (map deref))
          (pmap+ n func tail))))))

  #_
  (loop [result []
         items items]
    (let [[head tail] (split-at n items)]
      (if (seq head)
        (let [futures
              (for [item head]
                (future (func item)))]
          (recur (->> futures
                      doall
                      (mapv deref)
                      (into result))
                 tail))
        result))))