Отложенные вычисления и потоки Денис С. Мигинский

Загадка (letfn [(fact [n] (reduce * (range 1 n)))] (time (fact 1000)) (time (map fact (range )))) >> "Elapsed time: msecs" "Elapsed time: msecs« ;объясните результат профилирования

Разгадка (letfn [(fact [n] (reduce * (range 1 n)))] (time (fact 1000)) (time (nth (map fact (range )) 999))) >> "Elapsed time: msecs" "Elapsed time: msecs" ;время затрачено на востребование ;999-го элемента

Рекурсивное определение последовательности : попытка 1 (def naturals (cons 1 (map inc naturals))) >> #

Рекурсивное определение последовательности : попытка 2 (def naturals (lazy-seq (cons 1 (map inc naturals)))) (nth naturals 10) >> 11

Устройство « ленивых » последовательностей (def naturals (lazy-seq (cons 1 (map inc naturals)))) (nth naturals 10) ;вычисляем(cons 1 (map... ;вычисляем(cons (inc (first naturals)… ;... naturals обещание вычислить (cons 1 (map … naturals обещание (cons (inc (first naturals)) (map … 1 1 naturals обещание (cons (inc (second naturals)) (map …

Бесконечная последовательность ( поток ) чисел Фибоначчи ;рекурсивное определение (def fibs (lazy-cat '(0 1) (map + fibs (rest fibs)))) ;определение через порождающую функцию (let [fibs (map first (iterate (fn [[v1 v2]] [v2 (+ v1 v2)]) [0 1]))] (nth fibs 10))

« Ленивые » операции над последовательностями ;порождение «ленивой» последовательности ;из коллекции (seq coll) ;порождение «обещания» вычислить ;последовательность (lazy-seq & body) ;эквивалентно (concat (lazy-seq s1) ;(lazy-seq s2) … (lazy-cat s1 s2 & rest)

« Ленивые » операции над последовательностями ;порождение (x (f x) (f (f x)) … (iterate f x) ;получение части последовательности (take n coll) (for … (map … (filter … (rest …

« Неленивые » операции ;выбор элемента последовательности (nth coll n) (first coll) … ;принудительное вычисление (doall coll) (dorun coll) ;аналогично for, но допускает побочные ;эффекты и не возвращает значения. ;Похоже на each в Ruby. (doseq seq-expr & body) (reduce … (cons …

Представление времени и состояния Императивное программирование Функциональное программирование Модельное состояние Состояние переменныхНеизменяемая структура данных Изменение модельного состояния Изменение состояния переменных Порождение новой структуры данных в потоке (stream) Модельное время время Тождественно вычислительному времени Перемещение по потоку

Функциональные объекты с операцией отката Задача: необходимо реализовать универсальное (т.е. не привязанное к конкретной задаче/предметной области) представление объектов с операцией отката (undo)

Анализ задачи Механизм не должен раскрывать детали своей реализации (принцип абстракции) Механизм не должен ничего знать про структуру состояния объекта и набор операций над ним (требование универсальности) Необходимо предоставлять прозрачный доступ к объекту: инициализация объекта получение состояния объекта изменение состояния объекта Должна быть реализована операция undo

Проектирование : API ;порождение объекта (defn object [init-state] …) ;получение состояния объекта (defn state [obj] …) ;замена состояния объекта (defn replace-state [obj new-state]…) ;изменение состояния мутатором (defn change-state [obj mutator] …) ;возврат в предыдущее состояние (defn undo [obj] …)

Реализация (defn object [state] (list state)) (defn state [obj] (first obj)) (defn replace-state [obj new-state] (cons new-state obj)) (defn change-state [obj mutator] (replace-state obj (mutator (state obj)))) (defn undo [obj] (rest obj))

Покрытие тестами (test/is (= (state (object 1)) 1)) (test/is (= (state (replace-state (object 1) 2)) 2)) (test/is (= (state (change-state (object 1) inc)) 2)) (test/is (= (state (undo (replace-state (object 1) 2))) 1)) ;особые случаи (test/is (= (state (undo (object 1))) nil)) (test/is (= (state (replace-state (undo (object 1)) 2)) 2))

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

Задача С 3: численное интегрирование с потоками Модифицировать решение задачи C2 таким образом, чтобы вместо мемоизации использовались потоки (streams, технически - бесконечные списки)