AP
коро — он чисто про стейт интерпретатора, остальное уже вокруг
Size: a a a
2020 April 10
AP
allter
Кстати, в Coro, всё-таки, есть поддержка тредов операционной системы? Когда-то изучал, но забыл. Это сильное утверждение в начале перлдока по Coro ("the only real threads in perl") очень сильно сбивает.
вот такое есть: https://metacpan.org/pod/Coro::Multicore
b
> Coro::Multicore - make coro threads on multiple cores with specially supported modules
"with specially supported modules" как бы намекает, что работать не будет, в общем случае.
"with specially supported modules" как бы намекает, что работать не будет, в общем случае.
AP
я сам ни разу не пользовался, не могу про мультикоре проконсультировать
VG
всё-таки кондвары в АЕ - форменное блядство, если я отправляю синхронным воркерам запрос и делаю send на первом удачном, у остальных ляжет в очередь и вывалится мне в другой раз, портя потом мне поток
for my $layer (sort { $b <=> $a } keys %whohas) {
AE::log info => "trying to decode layer $layer";
$spin->begin;
$decoders{$layer}->{proc}->('tl_unpack_obj', $hash, $stream, sub {
my ($consumed, $obj) = @_;
AE::log debug => "decoder $layer returned consumed=$consumed obj=%s", defined $obj ? ref $obj : 'undef';
if ($consumed && $obj) {
$ext_obj = $obj;
$successful = $layer;
$spin->send($consumed);
} else {
AE::log error => "decoder $layer has hash but failed decode";
delete $whohas{$layer};
$spin->end;
}
});
}
my $trim = $spin->recv;
вот шо мне теперь, на каждого отдельный condvar заводить?!
for my $layer (sort { $b <=> $a } keys %whohas) {
AE::log info => "trying to decode layer $layer";
$spin->begin;
$decoders{$layer}->{proc}->('tl_unpack_obj', $hash, $stream, sub {
my ($consumed, $obj) = @_;
AE::log debug => "decoder $layer returned consumed=$consumed obj=%s", defined $obj ? ref $obj : 'undef';
if ($consumed && $obj) {
$ext_obj = $obj;
$successful = $layer;
$spin->send($consumed);
} else {
AE::log error => "decoder $layer has hash but failed decode";
delete $whohas{$layer};
$spin->end;
}
});
}
my $trim = $spin->recv;
вот шо мне теперь, на каждого отдельный condvar заводить?!
AP
кондвары в АЕ надо понимать как пользовать. рецв без коро им противопоказан
b
Или возми
Future, они компонуются нормально, в развесистые if/else/cancel иерархииVG
там выше был похожий цикл с опросом и begin/end, но возвращают все - работает норм, только еще один кондвар надо иметь
b
Проблема с cv, что они плохо/ограниченно компонуюся.
VG
но один барьер ладно, а в цикле - это что-то за гранью уже
VG
Или возми
Future, они компонуются нормально, в развесистые if/else/cancel иерархииа циклы в них есть? :)
VG
ну и это просто языковая обертка, а не IPC-средство, насколько я помню
b
my $f = Future->needs_all($f1,$f2, ... $fn); - ждет все фьючи, или пока 1 из них не сфелится
my $g = Future->waits_all($f1, $f2, ... $n); - ждет все фьючи (закончилась либо сфэйлилась)
VG
а "первый успешный, остальные даже не запускать" есть? :)
b
ну и это просто языковая обертка, а не IPC-средство, насколько я помню
там под капотом, например в
Future::AnyEvent (или как-то так), всё-тавно что-то вроде $loop->run_once() unless $something_happen_in_a_future - т.е. тот же AE::CV, расширенныйAP
промисы — это недо-коро
b
а "первый успешный, остальные даже не запускать" есть? :)
my $f = $f1->then($f2, f3, ...);
$f->get;
$f->get;
AP
нахрена брать недо-коро, когда уже есть коро?
a
промисы — это недо-коро
Промисы - это почти нормальные монады, с которыми можно делать что хочешь. Но вроде все промисы, которые есть в Perl имеют небезопасные подводные камни наподобие пресловутого рекурсивного вызова кондвара.
AP
короче, делайте что хотите :)