Лучшая альтернатива pmap в Clojure для параллелизации умеренно недорогих функций по большим данным?

Используя clojure у меня есть очень большой объем данных в последовательности, и я хочу обработать его параллельно, с относительно небольшое количество ядер (4 - 8).

Самая легкая вещь сделать использовать pmap вместо map, для отображения моей обработки функционируют по последовательности данных. Но координация наверху приводит к чистому убытку в моем случае.

Я думаю, что причина - это pmap предполагает, что функция, отображенная через данные, является очень дорогостоящей. При рассмотрении исходного кода pmap это, кажется, создает a future для каждого элемента последовательности в свою очередь, таким образом, каждый вызов функции происходит на отдельном потоке (циклически повторяющийся по количеству доступных ядер).

Вот соответствующая часть источника pmap:

(defn pmap
  "Like map, except f is applied in parallel. Semi-lazy in that the
  parallel computation stays ahead of the consumption, but doesn't
  realize the entire result unless required. Only useful for
  computationally intensive functions where the time of f dominates
  the coordination overhead."
  ([f coll]
   (let [n (+ 2 (.. Runtime getRuntime availableProcessors))
         rets (map #(future (f %)) coll)
         step (fn step [[x & xs :as vs] fs]
                (lazy-seq
                 (if-let [s (seq fs)]
                   (cons (deref x) (step xs (rest s)))
                   (map deref vs))))]
     (step rets (drop n rets))))
  ;; multi-collection form of pmap elided

В моем случае отображенная функция не является настолько дорогой, но последовательность огромна (миллионы записей). Я думаю стоимость создания и разыменования, которое - много фьючерсов то, где параллельное усиление потеряно в издержках.

Мое понимание pmap корректный?

Есть ли лучший шаблон в clojure для этого вида более низкой цены, но в широком масштабе повторенной обработки, чем pmap? Я рассматриваю разделение на блоки последовательности данных так или иначе и затем выполнение потоков на больших блоках. Действительно ли это - разумный подход и какие clojure идиомы работали бы?