Я чо-то этим микроскопом начал столько гвоздей забивать

а async await для for/foreach въезжает в ЯЗЫК

а наши asyncSeq - это просто нугет

так что не совсем корректно

но в F# нет смысла асинкСек в кор либу вгонять так-то

https://twitter.com/isaac_abraham/status/1064920177375100930?s=12

https://twitter.com/isaac_abraham/status/1064920177375100930?s=12

тоже вставил 5 копеек

Утра!

У него там ещё гист есть к этому пропозалу. Но там чо-то сложно. Я написал в 3 пайпа с асинксеком.

тоже вставил 5 копеек

Ну кто бы сомневался:))))

Ну кто бы сомневался:))))

а чо бы нет!

мне никогда Async.Parallel не нравился. крайне бесполезная имплементация

там даже уровень параллелизма не задать

и т.к. Asynс работает на тред пуле, запуск Async.Parallel на массиве в 1000 элементов унизит этот самый тредпул.

нахера он нужен - неясно

Угу...

А гопак с асинксеком в этом примере - прям братья-близнецы :)

На этом да. Апи гопака просто побольше, а так мысль та же

и т.к. Asynс работает на тред пуле, запуск Async.Parallel на массиве в 1000 элементов унизит этот самый тредпул.

Странно что оно не как Parallel.ForEach реализовано

Только разные отцы!

Странно что оно не как Parallel.ForEach реализовано

вот да, параллел.форЫч отличный, настраиваемый

и т.к. Asynс работает на тред пуле, запуск Async.Parallel на массиве в 1000 элементов унизит этот самый тредпул.

А это не то же самое что линкюшный asParallel?

А это не то же самое что линкюшный asParallel?

я не уверен как линкушный asParallel реализован, но не думаю что настолько же тупо

А это не то же самое что линкюшный asParallel?

Нет, оно умное там

Там несколько стратегий по чанкованию и тп

Вот как НЕ надо делать берут все пришедшие таски и хуярят через QueueWorkItem в шедулер https://github.com/Microsoft/visualfsharp/blob/87ea864488b2b7223ce0da1bfe3150df375b7b14/src/fsharp/FSharp.Core/async.fs#L1254

имплементация от бога просто

я не уверен как линкушный asParallel реализован, но не думаю что настолько же тупо

Он отличный, я его везде всунул и на его примере несу свет в массы (в виде иммутабельности и композабельности)

Он отличный, я его везде всунул и на его примере несу свет в массы (в виде иммутабельности и композабельности)

переходи на стримы! (можно на гопак, но асинкСек тоже пойдёт)

можно и на акку

слезть нереально. Потом уже стрим головного мозга начинается

везде мерещатся

Опиоиды

ВСЁ ПОТОК ДАННЫХ

Меня тогда точно выгонят ) но это давно пора сделать

Меня тогда точно выгонят ) но это давно пора сделать

акка стримы для С# нормальное апи имеют. Для F# не очень, т.к. некарированые функции и обёрток нормальных нет

но кто-то пилил, я давно видел какую-то альфу, не интересовался

ВСЁ ПОТОК ДАННЫХ

Всё тлен

слезть нереально. Потом уже стрим головного мозга начинается

Вот тут полностью поддерживаю, акка стримы, да и в принципе все реактивные стримы подобного плана очень клёвые.

Потом удивляешься как без них жил

акка стримы для С# нормальное апи имеют. Для F# не очень, т.к. некарированые функции и обёрток нормальных нет

Василий говорит, что акка стримы збс.

Василий говорит, что акка стримы збс.

я тоже так говорю, я лично (я лично) гопаковскими пользуюсь только потому что у них человеческое лицо для F# из каропки

меньше забот

Всё тлен

всё стрим. Вот чатик наш это стрим сообщений. А сообщения - стрим символов.

а ты подписался на стрим???

В акка стримах ещё прикольно, что до передачи в материализатор - они просто описание графа данных и соотвественно, при должном желании можно свой кастомный материализатор написать, если хочется чего-то совсем экзотического.

В акка стримах ещё прикольно, что до передачи в материализатор - они просто описание графа данных и соотвественно, при должном желании можно свой кастомный материализатор написать, если хочется чего-то совсем экзотического.

ну, это обычный лейзи стрим, удивил. АсинСек и Гопак такие же

т.е. они итерируются по запросу, пока не фолдишь, не итерируешь (не материализиурешь), они даже не почешутся исполнятся

соответственно фолдеров, итераторов (материализаторов) можно хоть тонну навесить на один и тот же стрим

и все разные!

ну, это обычный лейзи стрим, удивил. АсинСек и Гопак такие же

Я просто гопаковские стримы не трогал, поэтому не знаю насколько в них это возможно.

Я просто гопаковские стримы не трогал, поэтому не знаю насколько в них это возможно.

это возможно везде где реализовано отложенное исполнение

это возможно везде где реализовано отложенное исполнение

Ну мало ли.

так асинкЕнумерабл это вообще что, как он от обсервабл отличается?

Я из реактивных ленивых стримов только скаловские akka-stream и fs2 трогал.

а т.к. FSharp.Async и Hopac.Job ленивые - то в них можно

так асинкЕнумерабл это вообще что, как он от обсервабл отличается?

он пулл, а обсёрвалбл - пуш

IObservable, это ты подписываешься на источник данных и не контролируешь сколько он тебе пошлёт, он тебя может завалить пушами, это ты сам разгребать должен Это push модель

Enumerable (и соответственно AsyncEnumerable) это ты ПРОСИШЬ продьюсер дать тебе элемент, вытягивая его когда надо консьюмеру это pull модель

push модель работает на пределе продьюсера (без простоя), но с простоями консьюмера или его оверфлоу (соответстенно нужны стратегии дропа сообщений чтобы не было этого оверфлоу) pull модель работает на пределе консьюмера (без простоя), но с простоями продьюсера

Ayrat а в твоём примере с гопаком - результаты не будут ли в обратном порядке?

акка стримы имеют бекпрешур, т.е. пропагирование простоев консьюмера на продьюсера (апстрим) чтобы он охладил трахание и не посылал больше

соответстенно эта пропагация работае на все этапы стримы вплоть до сорца. Т.е. сорс не будет больше генерить элементов если даунстрим НЕ ТАЩИТ

Ayrat а в твоём примере с гопаком - результаты не будут ли в обратном порядке?

будут конечно :D

но это эффективнее на больших стримах чем в ресайз эррей складывать

но только на ОЧЕНЬ больших стримах

до 5 ресайзов вполне норм в ресайз эррей сложить. Там начальные переаллокации не очень больше, а вот последние уже не очень

вот был бы наш лист мутабельным линкед листом, то для него есть очень крутой алгоритм переворачивания стрелок линков без аллокаций

красота была бы. Сложил всё без переаллокаций в линкед лист в обратном порядке, а потом мутируя лист стрелки перевернул и всё

вот был бы наш лист мутабельным линкед листом, то для него есть очень крутой алгоритм переворачивания стрелок линков без аллокаций

При условии, что есть указатель на хвост?

вот был бы наш лист мутабельным линкед листом, то для него есть очень крутой алгоритм переворачивания стрелок линков без аллокаций

Если бы у бабушки...

При условии, что есть указатель на хвост?

да, ну или придётся его получить пройдя разок вообще LinkedList в реализациях во всех какие я видел хранит First/Last линки

это ж дёшево и помогает

это ж дёшево и помогает

Ну при таком условии да

хотя стой, я тут подумал что можно и без ссылки на последний такой лист A -> B -> C начинаем с A смотрим что впереди: если есть элемент: сохраняем линк на него и обнуляем линк у A идем по сохраннёному элементу запоминаем его NextLink в локальную переменную Перезаписываем линк у B чтобы он смотрел на А запускаем тот же алгоритм для элемента во временно сохраннёном линке если элемента впереди A нет, заканчиваем алгоритм

надо накидать псевдокод, вроде должно работать

В теории да

Переворот за один проход

ну да