← retour au collage›Modifier / dupliquer

Collage sans titre

#9NzSPMQ6dXpublic / publicnouvelle version

par @slepp créé 2 months ago aucune expiration 1.3 KB syntaxe: hew

Vos changements créent un nouveau collage lié à celui-ci — l’original reste intact.

nouvelle version Vos changements créent un nouveau collage lié à celui-ci — l’original reste intact.

Visibilité Fil public Accès public

Note de changement (facultatif)

Ce collage sera affiché dans le fil public. Changez la visibilité si vous voulez seulement le partager par lien.

Annuler

// Structured concurrency in Hew: a scope owns its child tasks and joins them
// all before the scope expression returns. Tasks are forked with `fork { ... }`
// and run on real OS threads; the enclosing `scope { }` is the join boundary.
//
// Constraints in this build: spawning happens inside an actor handler (which
// carries the execution context); each forked function is a zero-argument,
// unit-returning free function. Nested scopes compose, and an empty
// `after(d) {}` arms a cancellation deadline on the surrounding scope.

fn fetch_orders() {
    println("fetched orders");
}

fn fetch_inventory() {
    println("fetched inventory");
}

fn settle() {
    println("reconciled");
}

actor _Pipeline {
    receive fn run() -> i64 {
        // Outer scope: two siblings fork concurrently and BOTH join here.
        scope {
            after(5s) {}
            fork {
                fetch_orders();
            }
            fork {
                fetch_inventory();
            }
            // Nested scope: its own child joins before the outer scope drains.
            scope {
                fork {
                    settle();
                }
            };
        };
        0
    }
}

fn main() -> i64 {
    let p = spawn _Pipeline;
    match await p.run() {
        Ok(code) => code,
        Err(_e) => 1,
    }
}