Идиоматический clojure для создания отчетов прогресса?
Как я должен контролировать прогресс отображенной функции в clojure?
При обработке записей на императивном языке я часто печатаю сообщение время от времени, чтобы указать, как далеко дела шли, например, создание отчетов о каждых 1 000 записей. По существу это считает повторения цикла.
Я задавался вопросом, что приближается, я мог взять к этому в clojure, где я отображаю функцию по своей последовательности записей. В этом случае, печатающем сообщение (и даже проводящем подсчет прогресса), кажется, по существу побочные эффекты.
Что я придумал, до сих пор похож:
(defn report
[report-every val cnt]
(if (= 0 (mod cnt report-every))
(println "Done" cnt))
val)
(defn report-progress
[report-every aseq]
(map (fn [val cnt]
(report report-every val cnt))
aseq
(iterate inc 1)))
Например:
user> (doall (report-progress 2 (range 10)))
Done 2
Done 4
Done 6
Done 8
Done 10
(0 1 2 3 4 5 6 7 8 9)
Есть ли другие (лучшие) способы достигнуть этого эффекта?
Есть ли какие-либо ловушки в том, что я делаю? (Я думаю, что сохраняю лень и не держу голову, например.)
3 ответа
Самое главное в клоуре - можно прикрепить отчёт к самим данным, а не к коду, который делает вычисления. Это позволяет разделить эти логически обособленные части. Вот фрагмент из моего misc.clj, который я использую практически в каждом проекте:
(defn seq-counter
"calls callback after every n'th entry in sequence is evaluated.
Optionally takes another callback to call once the seq is fully evaluated."
([sequence n callback]
(map #(do (if (= (rem %1 n) 0) (callback)) %2) (iterate inc 1) sequence))
([sequence n callback finished-callback]
(drop-last (lazy-cat (seq-counter sequence n callback)
(lazy-seq (cons (finished-callback) ()))))))
затем оберните Reporter вокруг ваших данных и передайте результат в функцию обработки.
(map process-data (seq-counter inc-progress input))
Я бы, наверное, выполнял отчетность в агенте. Что-то вроде этого:
(defn report [a]
(println "Done " s)
(+ 1 s))
(let [reports (agent 0)]
(map #(do (send reports report)
(process-data %))
data-to-process)
Я не знаю ни одного существующего способа сделать это, может быть, было бы неплохо просмотреть документацию clojure.contrib, чтобы посмотреть, если уже что-то есть. Тем временем, я посмотрел на ваш пример и немного прояснил его.
(defn report [cnt]
(when (even? cnt)
(println "Done" cnt)))
(defn report-progress []
(let [aseq (range 10)]
(doall (map report (take (count aseq) (iterate inc 1))))
aseq))
Вы движетесь в правильном направлении, хотя этот пример слишком прост. Это дало мне представление о более обобщенной версии Вашей функции создания отчетов. Эта функция возьмет на себя функцию, похожую на карту, функцию, которую нужно отобразить, функцию отчета и набор коллекций (или начальное значение и коллекцию для тестирования сократить).
(defn report-progress [m f r & colls]
(let [result (apply m
(fn [& args]
(let [v (apply f args)]
(apply r v args) v))
colls)]
(if (seq? result)
(doall result)
result)))
Часть seq? существует только для использования с сокращением, которое не обязательно возвращает последовательность. С помощью этой функции мы можем переписать вашу пример подобный:
user>
(report-progress
map
(fn [_ v] v)
(fn [result cnt _]
(when (even? cnt)
(println "Done" cnt)))
(iterate inc 1)
(range 10))
Done 2
Done 4
Done 6
Done 8
Done 10
(0 1 2 3 4 5 6 7 8 9)
Тест функции фильтра:
user>
(report-progress
filter
odd?
(fn [result cnt]
(when (even? cnt)
(println "Done" cnt)))
(range 10))
Done 0
Done 2
Done 4
Done 6
Done 8
(1 3 5 7 9)
И даже функция уменьшения:
user>
(report-progress
reduce
+
(fn [result s v]
(when (even? s)
(println "Done" s)))
2
(repeat 10 1))
Done 2
Done 4
Done 6
Done 8
Done 10
12