Почему pmap|reducers/map не использует все ядра процессора?

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

Моя первая попытка включала pmap для выполнения тяжелой работы, я полагал, что это по существу задействует все ядра моего процессора.

(ns multicore-parsing.core
  (:require [cheshire.core :as json]
            [iota :as io]
            [clojure.string :as string]
            [clojure.core.reducers :as r]))


(defn words-pmap
  [filename]
  (letfn [(parse-with-keywords [str]
            (json/parse-string str true))
          (words [book]
            (string/split (:contents book) #"\s+"))]
    (->>
     (io/vec filename)
     (pmap parse-with-keywords)
     (pmap words)
     (r/reduce #(apply conj %1 %2) #{})
     (count))))

Хотя кажется, что он использует все ядра, каждое ядро ​​​​редко использует более 50% своей мощности, я предполагаю, что это связано с размером пакета pmap, и поэтому я наткнулся на относительно старый вопрос, где в некоторых комментариях упоминается библиотека clojure.core.reducers.

Я решил переписать функцию, используя reducers/map:

(defn words-reducers
  [filename]
  (letfn [(parse-with-keywords [str]
            (json/parse-string str true))
          (words [book]
            (string/split (:contents book) #"\s+"))]
  (->>
   (io/vec filename)
   (r/map parse-with-keywords)
   (r/map words)
   (r/reduce #(apply conj %1 %2) #{})
   (count))))

Но загрузка процессора хуже, и для завершения даже требуется больше времени по сравнению с предыдущей реализацией:

multicore-parsing.core=> (time (words-pmap "./dummy_data.txt"))
"Elapsed time: 20899.088919 msecs"
546
multicore-parsing.core=> (time (words-reducers "./dummy_data.txt"))
"Elapsed time: 28790.976455 msecs"
546

Что я делаю неправильно? Является ли загрузка mmap + редукторы правильным подходом при разборе большого файла?

РЕДАКТИРОВАТЬ: это файл, который я использую.

EDIT2: вот тайминги с iota/seq вместо iota/vec:

multicore-parsing.core=> (time (words-reducers "./dummy_data.txt"))
"Elapsed time: 160981.224565 msecs"
546
multicore-parsing.core=> (time (words-pmap "./dummy_data.txt"))
"Elapsed time: 160296.482722 msecs"
546