NK
что-то я видимо проглядел, сейчас пересмотрю
Size: a a a
2020 November 18
VG
unshift_read( chunk => 5, там, например
VG
там этого у него бахато
NK
да, увидел в доке. А как не получать новых каллбеков, пока я не обработаю текущий? И чтобы переданные данные не потерялись за это время
DF
да, увидел в доке. А как не получать новых каллбеков, пока я не обработаю текущий? И чтобы переданные данные не потерялись за это время
ты языки не путаешь? :) У тебя обработка коллбека синхронная, пока ты вычитываешь буфер и его обрабатываешь никаких новых коллбеков не будет. Ну если специально не заморачиваться.
NK
ты языки не путаешь? :) У тебя обработка коллбека синхронная, пока ты вычитываешь буфер и его обрабатываешь никаких новых коллбеков не будет. Ну если специально не заморачиваться.
я примерно вообще не умею AE и вообще асинхронное ни на одном языке. Читаю документацию вот сейчас и про то что каллбеки синхронны - нигде пока не увидел. Или я где-то не там читаю?
NK
(но да, логично ожидать асинхронные каллбеки и в js оно вроде так)
DF
Ну AE работает в один поток, соответственно в один момент времени может исполняться физически только один коллбек. Об этом где-то есть в доке, но мельком.
VO
а я бы тупо на селектах наколхозил...
DF
ну в js точно так же
DF
а я бы тупо на селектах наколхозил...
а смысл самому ioloop колхозить когда он уже есть?
VO
проще
NK
так. А вот если у меня два порта и я создал два AnyEvent::Handle и у меня в одном случился каллбек - во втором он не случится пока я не обработаю каллбек в первом?
SZ
я примерно вообще не умею AE и вообще асинхронное ни на одном языке. Читаю документацию вот сейчас и про то что каллбеки синхронны - нигде пока не увидел. Или я где-то не там читаю?
Async ≠ multi-threaded.
Оно в один поток выполняется, просто на блокирующих сисколлах умеет переключать контекст и делать другие вещи, подменив сисколлы на неблокирующие
Оно в один поток выполняется, просто на блокирующих сисколлах умеет переключать контекст и делать другие вещи, подменив сисколлы на неблокирующие
SZ
Наоборот, сложнее :)
DF
так. А вот если у меня два порта и я создал два AnyEvent::Handle и у меня в одном случился каллбек - во втором он не случится пока я не обработаю каллбек в первом?
для твоего кода да
SZ
так. А вот если у меня два порта и я создал два AnyEvent::Handle и у меня в одном случился каллбек - во втором он не случится пока я не обработаю каллбек в первом?
Конечно. Event loop получит управление только когда коллбэк отработает или «заблокирует»
VO
да ну.
while ( $nfound = select( $rout = $rin, undef, $eout = $ein, 10 ) )
и там тупо по дескриптору экземпляр брать
while ( $nfound = select( $rout = $rin, undef, $eout = $ein, 10 ) )
и там тупо по дескриптору экземпляр брать
SZ
да ну.
while ( $nfound = select( $rout = $rin, undef, $eout = $ein, 10 ) )
и там тупо по дескриптору экземпляр брать
while ( $nfound = select( $rout = $rin, undef, $eout = $ein, 10 ) )
и там тупо по дескриптору экземпляр брать
Ну надо будет ещё nfound хандлить, очередь городить и т.д
NK
для твоего кода да
т.е. чтобы разные порты обрабатывались одновременно - мне нужно что-то для multi-threaded? А что?