← voltar para a publicação›Editar / bifurcar

Publicação sem título

#9NzSPMQ6dXpublic / publicnova versão

por @slepp criado 2 days ago sem expiração 1.3 KB sintaxe: hew

Suas alterações criam uma nova publicação vinculada a esta — a original não é alterada.

nova versão Suas alterações criam uma nova publicação vinculada a esta — a original não é alterada.

Visibilidade Feed público Acesso public

Nota da alteração (opcional)

Esta publicação aparecerá no feed público. Altere Visibilidade se quiser compartilhar apenas por link.

Cancelar

// 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,
    }
}