Início / coding / Perguntas / 79550260
Accepted
Pawel Pabian bbkr
Asked: 2025-04-02 17:32:41 +0800 CST

Use gather/take com raça

  • 772

Posso paralelizar a execução usando o Hyper e funciona:

$ raku -e 'race for (^8).race(batch => 1, degree => 4) {sleep rand; .say}'
0
3
5
2
1
7
4
6

Mas como posso adicionar comportamento gather/take a esse loop?

Nessa abordagem, take não detectará que está encapsulado no contexto gather:

$ raku -e '
    my @x = gather race for (^8).race(batch => 1, degree => 4) {
        sleep rand;
        take $_;
    };
    @x.say
'

Died at:
    take without gather

Nessa abordagem, o gather consumirá o HyperSeq sem realmente "hiper" sobre ele:

$ raku -e '
    my @x = race gather for (^8).race(batch => 1, degree => 4) {
        sleep rand;
        take $_;
    };
    @x.say
'

[0 1 2 3 4 5 6 7]
raku

3 respostas

  1. O que você está pedindo, por baixo dos panos, é uma estrutura de dados paralelizada (nesse caso, o contêiner para os resultados de gather/take) que proteja as operações de gravação de vários threads. Embora a sintaxe do raku não impeça uma implementação como essa, ela não visa tornar as estruturas de dados padrão atômicas, pois isso adiciona uma sobrecarga substancial e potencial para deadlocks. Nesse tipo de requisito, o raku tem uma ótima sintaxe de simultaneidade que ajudará você a mapear/reduzir seus cálculos em vários processos.

    • 3

  2. Veja a nota na parte inferior da documentação do gather take que menciona um problema semelhante com react/whenever, ou seja, que não há um manipulador para a exceção de controle nos novos threads. Por exemplo:

    $ raku -e 'say gather { await start { take 42 } };'
An operation first awaited:
  in block <unit> at -e line 1

Died with the exception:
    take without gather
      in block  at -e line 1
    • 2
  3. Best Answer

    Posso paralelizar a execução usando racee funciona

    Mas somente às terças-feiras. Imagino que você já saiba essa primeira parte da minha resposta, mas o compilador tem permissão para decidir se deve paralelizar. Para citar incorretamente, mas de forma justa, o documento de design relevante com minha ênfase adicional :

    hyper/ race solicitar (mas não exigir ) avaliação paralela.

    ----

    Mas como posso adicionar gather/ takecomportamento a esse loop?

    Citando o documento de design novamente:

    Você pode pensar nisso racecomo um gathercom um ' try take start {...}' em computação paralela.

    Ou seja, usar racesignifica que você já obtém automaticamente o comportamento gather/ takede graça, sem realmente ter que usar gather/ take.

    ----

    gather race ...morre com mensagem de errotake without gather

    race gather ..."funciona" mas não paraleliza

    Não sei bem o que fazer com esses dois cenários.

    ----

    Em sua resposta a Quais mecanismos de simultaneidade são fornecidos pelo Raku ...? , Jonathan Worthington menciona isto sobre gather/ take:

    • O mecanismo gather/ takepara produzir valores preguiçosamente. Isso é visto em várias linguagens como funções geradoras; no Raku, no entanto, não há um único limite de quadro de pilha, então elas são poderosas como coroutine. (Isso não é de nenhum contexto envolvendo programação assíncrona, mas ainda atende à definição de simultaneidade).

    Não tenho certeza sobre o parêntesis. Não consigo analisar "This isn't of in any context developing", e a última parte da frase parece ambígua.

    ----

    Uma coisa que me chamou a atenção é que gather/ takeé default para lazy . O uso de raceshould substitui isso e o torna eager , mas pensei comigo mesmo que o Rakudo poderia plausivelmente ter um bug que o deixava lazy e me perguntei se o comportamento lazy estava levando ao comportamento visto no seu race gather ...código. No entanto, tentei inserir um explicit eageronde pensei que poderia ser necessário e nada do que tentei fez diferença.

    • 1

relate perguntas