I
https://github.com/basho/sidejob но я не буду это использовать;)
Size: a a a
2020 August 10
A
А разве в rpc подобного нет?
там оно есть, но ниточек этим всем рулить мало. Тот же yield может висеть до второго пришествия
VS
Igor
там нет ограничения на количество вызвов. Если я пытаюсь всё сразу обрабатывать - получается плохо)
если по-простому, то как-то так:
https://gist.github.com/eryx67/9580e00fe0f71bbe407586ee18b9fa29
https://gist.github.com/eryx67/9580e00fe0f71bbe407586ee18b9fa29
I
спасибо)
ИИ
если по-простому, то как-то так:
https://gist.github.com/eryx67/9580e00fe0f71bbe407586ee18b9fa29
https://gist.github.com/eryx67/9580e00fe0f71bbe407586ee18b9fa29
Он их пачками выполняет получается? Т.е. run/spawn/wait можно на заготовки из rpc заменить?
AK
если по-простому, то как-то так:
https://gist.github.com/eryx67/9580e00fe0f71bbe407586ee18b9fa29
https://gist.github.com/eryx67/9580e00fe0f71bbe407586ee18b9fa29
мне кажется ошибка есть в этом коде, wait_job_result({Pid, Ref}) ->
receive
{'DOWN', Ref, _, _, normal} -> receive {Pid, Result} -> Result end;
{'DOWN', Ref, _, _, Reason} -> {error, Reason}
end.
тут же не гарантируется что между {'DOWN', Ref, _, _, normal} и {Pid, Result} не влезет никто?
receive
{'DOWN', Ref, _, _, normal} -> receive {Pid, Result} -> Result end;
{'DOWN', Ref, _, _, Reason} -> {error, Reason}
end.
тут же не гарантируется что между {'DOWN', Ref, _, _, normal} и {Pid, Result} не влезет никто?
VS
Он их пачками выполняет получается? Т.е. run/spawn/wait можно на заготовки из rpc заменить?
я не помню, что там в
rpc, идея простая и тупая, дальше можно развивать по надобностиAK
надо тестить..
VS
мне кажется ошибка есть в этом коде, wait_job_result({Pid, Ref}) ->
receive
{'DOWN', Ref, _, _, normal} -> receive {Pid, Result} -> Result end;
{'DOWN', Ref, _, _, Reason} -> {error, Reason}
end.
тут же не гарантируется что между {'DOWN', Ref, _, _, normal} и {Pid, Result} не влезет никто?
receive
{'DOWN', Ref, _, _, normal} -> receive {Pid, Result} -> Result end;
{'DOWN', Ref, _, _, Reason} -> {error, Reason}
end.
тут же не гарантируется что между {'DOWN', Ref, _, _, normal} и {Pid, Result} не влезет никто?
если толь кто-то украдет референс, но это дорого - проще разбомбить тактической ракетой.
ИИ
я не помню, что там в
rpc, идея простая и тупая, дальше можно развивать по надобностиЯ так понял тс хочет пул а не пачку
AK
референс не надо красть, просто два сообщения перепутаться могут
AK
или такого быть не может.. блин надо сообразить :))
VS
референс не надо красть, просто два сообщения перепутаться могут
не могут, если все выполняется, как написано
VS
Я так понял тс хочет пул а не пачку
я так понял, там есть пул и задача - его не перегрузить очень большими тысячами параллельных запросов
AK
erlang:spawn_monitor(fun() -> Parent ! {self(), Fun()} end).
От этой функции DOWN и сообщение прилетят не атомарно же?
От этой функции DOWN и сообщение прилетят не атомарно же?
AK
мне кажется таки ошибка, могут местами в списке перепутаться ответы
VS
без разницы,
receive штука селективнаяAK
но код я откопирую себе :)
AK
а да, точно, все правильно, пид же контролится
AK
нет ошибки