Comment puis-je propager et intercepter les erreurs lancées dans un autre thread dans Raku?

Quelle est la meilleure façon de propager les erreurs à partir d'un thread séparé (par exemple, le bloc de démarrage, Proc :: Async ou un sous-conteneur les contenant). Le simple encapsulage du code qui dérive un nouveau thread dans un bloc try / CATCH ne fonctionne pas, et l'utilisation de l'attente ne fonctionne que selon la valeur de retour de la sous-routine (c'est-à-dire qu'un sous-retour ne fonctionnera pas avec l'approche de l'attente).

Utilisez await.

Par exemple, remplacez ces trois lignes dans votre code:

foo;
bar;
baz;

avec:

await foo, bar, baz;

Théoriquement, ce code devrait mourir :

À partir de la version 6.d du langage, le préfixe d'instruction de début utilisé dans le contexte de récepteur attachera automatiquement un gestionnaire d'exceptions. Si une exception se produit dans le code donné, elle sera imprimée et le programme se fermera alors, comme si elle était levée sans aucun préfixe d'instruction de démarrage impliqué.

use v6.c;
start { die }; sleep ⅓; say "hello"; # OUTPUT: «hello␤» 

use v6.d;
start { die }; sleep ⅓; say "hello";
# OUTPUT: 
# Unhandled exception in code scheduled on thread 4 
# Died 
#     in block  at -e line 1 

Dans ce cas, c'est une situation étrange parce que vous ne perdez pas la promesse (vous la rendez), mais finalement vous la perdez parce que vous l'exécutez dans un contexte vide.

La même documentation vous donne la solution: ne coulez pas le contexte:

# Don't sink it: 
my $ = start { die }; sleep ⅓; say "hello"; # OUTPUT: «hello␤» 

# Catch yourself: 
start { die; CATCH { default { say "caught" } } };
sleep ⅓;
say "hello";

Puisque votre programme ne meurt pas, je dirais que vous êtes dans la deuxième situation. Pour une raison quelconque, ce n'est pas coulé. Mais quelle que soit la situation, la solution est la même: vous devez intercepter l'exception dans le même bloc de code.

Solution: awaitla promesse (qui ne la coulera pas) ou l'affecter à une variable, de sorte que le code environnant meurt aussi. Mais en répondant à votre OP, non, vous ne pouvez pas intercepter une exception d'un autre thread, de la même manière que vous ne pouvez pas intercepter une exception d'un autre bloc.

En suivant la convention utilisée dans Go pour passer les erreurs des routines go en utilisant des canaux, j'ai trouvé la même approche pour travailler dans Raku. On peut utiliser un canal pour envoyer des erreurs hors du code asynchrone à gérer par le thread principal.

Exemple:

my $errors = Channel.new;

my $err-supply = $errors.Supply;
$err-supply.tap(-> $e {say "handle error: $e"});

start {
    die "something went horribly wrong";

    CATCH {
        default {
            $errors.send($_);
        }
    }
}

sleep 1;