MB
Ну да, только mapv кажется как будто не для этой задачи придуман
Size: a a a
2020 November 05
MB
В голове хочется просто map сделать
MB
Вообще я собирался doall поставить после первого мапа, тогда вроде правильно должно сработать
ST
Ну вот и как идиоматично все сразу запустить?)
если не сильно задумываясь, то можно pmap
а вообще зависит от того, что у тебя за коллекция такая, и сколько в ней элементов
http/get тоже тебе 1000 запросов сразу не будет делать наружу
а вообще зависит от того, что у тебя за коллекция такая, и сколько в ней элементов
http/get тоже тебе 1000 запросов сразу не будет делать наружу
MB
если не сильно задумываясь, то можно pmap
а вообще зависит от того, что у тебя за коллекция такая, и сколько в ней элементов
http/get тоже тебе 1000 запросов сразу не будет делать наружу
а вообще зависит от того, что у тебя за коллекция такая, и сколько в ней элементов
http/get тоже тебе 1000 запросов сразу не будет делать наружу
Ну мне нужно около 100 :)
ST
Вообще я собирался doall поставить после первого мапа, тогда вроде правильно должно сработать
ну, mapv будет быстрее
и вообще doall не место в нормальном коде
и вообще doall не место в нормальном коде
MB
Кстати, я так и не понял, почему Рич решил, что ленивый map это хороший дефолт?
ST
Ну мне нужно около 100 :)
ну я сам так и писал, где мне нужно было 😊
(->> messages
(mapv #(future (send-message %)))
(mapv deref))
MB
Ладно, надо значит утилитки начинать колбасить
ST
Кстати, я так и не понял, почему Рич решил, что ленивый map это хороший дефолт?
ST
Ну вот и как идиоматично все сразу запустить?)
но вообще я бы использовал, наверное,
core.async/pipeline с контролируемым параллелизмомMB
Спасибо за советы)
ST
но вообще я бы использовал, наверное,
core.async/pipeline с контролируемым параллелизмомвыглядит, конечно, уже не так изящно
(time (let [from (->> (list 1 2 3) (async/to-chan!))
to (async/chan)
xf (map #(deref (future (Thread/sleep 1000) %)))]
(async/pipeline-blocking 10 to xf from true)
(async/<!! (async/into [] to))))
"Elapsed time: 1007.2854 msecs"
=> [1 2 3]
ST
выглядит, конечно, уже не так изящно
(time (let [from (->> (list 1 2 3) (async/to-chan!))
to (async/chan)
xf (map #(deref (future (Thread/sleep 1000) %)))]
(async/pipeline-blocking 10 to xf from true)
(async/<!! (async/into [] to))))
"Elapsed time: 1007.2854 msecs"
=> [1 2 3]
ну а в случае асинхронного апи от http можно использовать pipeline-async без deref и оформить как функцию, которая берёт коллекцию, асинхронную функцию над элементом, параллелизм — и возвращает уже обработанную коллекцию, над элементами которой уже производятся синхронные операции
ST
ну а в случае асинхронного апи от http можно использовать pipeline-async без deref и оформить как функцию, которая берёт коллекцию, асинхронную функцию над элементом, параллелизм — и возвращает уже обработанную коллекцию, над элементами которой уже производятся синхронные операции
в таком виде не будут создаваться дополнительные треды для параллельной обработки
MB
Вот кажется как будто не хватает функций в стандартной библиотеке)
MB
но их в целом несложно самому написать
AC
Кстати, я так и не понял, почему Рич решил, что ленивый map это хороший дефолт?
Видимо он хорошо сочетается с другими ленивыми преобразованиями
AC
Делаешь map, потом например take
MB
Ну в таком контексте понятно, но это кажется игрушкой