@gogolang - страница 409 - Telegram web archive

Daniel

а с green thread'ами типа такого рода "планирование" отпадает?))

вообще-то да. ты просто пишешь последовательный код. где надо - ждешь, где надо - вызываешь синхронный обработчик

Roman

streams.join(firstTask(...), secondTask(...)) .attach(stream { streams.race(thirdTask(...), fourthTask(...)) .attach(stream.close()) }) .failure(...)

Roman

это подход со стримами... позволяет относительно просто описывает довольно сложный асинхронный control flow

Daniel

коллега

Daniel

вы же сами видите, сколько тут синтаксического мусора

Aleksand

это подход со стримами... позволяет относительно просто описывает довольно сложный асинхронный control flow

при всем уважении это не просто и увольте от такого

Roman

я же неоднократно утверждал что синхронный код на green thread'ах читается проще))) я ВОВСЕ не спорю с этим я лишь представляю control flow решения со стороны асинхронного подхода

Roman

в event loop'е синхронный код не попишешь

Roman

но и callback'и там давным давно уже неактуальны

Roman

почти в любой среде GUI и с Node теперь даже на сервере у нас event loop

Aleksand

я хочу так await loop.parallel(Job(a), Job(a), loop.series(Job(a1), Job(a2)))

Roman

и код писать приходится именно асинхронно

Roman

я хочу так await loop.parallel(Job(a), Job(a), loop.series(Job(a1), Job(a2)))

ну.. хоти)) что я могу сказать

Aleksand

ну.. хоти)) что я могу сказать

я так и пишу, и отлично работает, просто не хочется это реализовывать самому внутри щелкая eventloop

Roman

я так и пишу, и отлично работает, просто не хочется это реализовывать самому внутри щелкая eventloop

streams подход разрабатывался для останавливаемых и отменяемых "потоков"

Roman

можно ли приостановить и продолжить или отменить во время исполнения async await ?

Aleksand

streams подход разрабатывался для останавливаемых и отменяемых "потоков"

в каком языке и для каких операций?

Aleksand

можно ли приостановить и продолжить или отменить во время исполнения async await ?

да

Roman

да

как это выглядит?

Aleksand

но тонкости есть везде свои

Aleksand

как это выглядит?

task.cancel например в питоне

Aleksand

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

Roman

в каком языке и для каких операций?

я на данный момент пишу реализацию для Qt Quick (языки: C++ & QML) самая первая проблема с которой мы тогда столкнулись это network filesystem API, а именно асинхронная по-чанковая загрузка больших файлов

Roman

task.cancel например в питоне

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

Roman

внутри одного стрима могут быть 4 последовательных из которых он состоит они могут быть либо atomic либо abortable

Aleksand

я на данный момент пишу реализацию для Qt Quick (языки: C++ & QML) самая первая проблема с которой мы тогда столкнулись это network filesystem API, а именно асинхронная по-чанковая загрузка больших файлов

ну обсуждаемый вопрос очень зависит от языка и платформы

Roman

и следственно если высокоуровневый стрим отменяем во время исполенения atomic стрима - дожидаемся его возвращаение ну и т.д. .. там парадигма много на что способна

Aleksand

я про c++ ничего не скажу

Сережа

qt quick это считай джаваскрипт

Сережа

с биндингами к с++

Roman

qt quick это считай джаваскрипт

JavaSctipt + C++ в одной связке

Aleksand

и следственно если высокоуровневый стрим отменяем во время исполенения atomic стрима - дожидаемся его возвращаение ну и т.д. .. там парадигма много на что способна

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

Roman

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

зато подразумевает свободную абстракцию отменяемых и приостанавливаемых "потоков"

Сережа

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

Aleksand

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

теперь пусть дадут удобные инструменты и синтаксис и все будут использовать

Сережа

это те, которые будущее пророчат функциональной парадигме

Anonymous

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

Эт хто?

Сережа

ботоны всякие

Сережа

https://stackoverflow.com/questions/35120082/how-to-get-started-with-akka-streams вот тут они на со резвятся

Roman

проблема наверное в терминологии

Roman

имеются ввиду не "stream" в качестве видео-потоков или подобного

Roman

на сайте QuickStreams я, надеюсь, довольно кратко и понятно определил значение стрима в данном контексте: https://qbeon.github.io/QuickStreams/

Roman

Aleksand

на сайте QuickStreams я, надеюсь, довольно кратко и понятно определил значение стрима в данном контексте: https://qbeon.github.io/QuickStreams/

это реинкарнация модели акторов? не?

Roman

это реинкарнация модели акторов? не?

не знаком, но маловероятно)

Aleksand

ну акка она про нее изначально вроде

Сережа

зачем на Qt выносить в QML стримы и т.д.? QML же чтобы квадратики двигать, а вся логика в c++ или тормозить будет?

Roman

очень похоже на стиль написания промисов, но мощнее: http.get(...) .retry([http.Timeout, http.BadGateway], 3) .attach(function(results) { // results arrived }) .repeat(3) .failure(function(error) { // error handling }) запускаем запрос http.get, если запрос валится по причине таймаута или badgateway - повторяем (максимум 3 раза), по успешному прибытию результатов 3 раза повторяем обработчик ну а иначе попадаем в failure

Roman

зачем на Qt выносить в QML стримы и т.д.? QML же чтобы квадратики двигать, а вся логика в c++ или тормозить будет?

QML это полноценный яп, никто не мешает писать приложения полностью на QML, если все нужные performance-критичные API реализованы на C++ то всё будет летать

Roman

JavaScript достаточно быстрый для бизнес логики связывающей элементы API

Roman

к тому-же QML намного проще C++, т.е. за те-же деньги больше приложения))