Go Academy · Lezione

Modelli fan-in e fan-out

Unire più canali e distribuire il lavoro

Modelli fan-in e fan-out è una lezione Go Academy gratuita su CoddyKit. Questa è la lezione 3 di 4. Puoi leggere la lezione completa qui gratuitamente — poi esercitati direttamente nel browser con un editor di codice integrato e un tutor IA disponibile 24/7. Fa parte del percorso di apprendimento Go Academy, e i tuoi progressi si sincronizzano tra il web e l'app CoddyKit. Il corso Go Academy include 4 lezioni in totale.

Che cos'è il fan-out

Il fan-out distribuisce il lavoro da un canale a più goroutine, consentendo l'elaborazione parallela. Ogni worker riceve dallo stesso canale di input.

Esempio di fan-out

Avvii N worker che leggono tutti da un canale jobs condiviso:

func fanOut(jobs <-chan Job, n int) {
    for i := 0; i < n; i++ {
        go func() {
            for job := range jobs {
                process(job)
            }
        }()
    }
}

Che cos'è il fan-in

Il fan-in unisce più canali in uno solo, così un unico consumatore può leggere i risultati di più produttori.

Fan-in con goroutine

Avvii una goroutine per ogni canale di input; ogni goroutine inoltra i valori a un canale di output condiviso.

func fanIn(cs ...<-chan int) <-chan int {
    out := make(chan int)
    var wg sync.WaitGroup
    for _, c := range cs {
        wg.Add(1)
        go func(ch <-chan int) {
            defer wg.Done()
            for v := range ch { out <- v }
        }(c)
    }
    go func() { wg.Wait(); close(out) }()
    return out
}

Fan-in con select

Per un numero fisso di canali di input, un ciclo select è più semplice rispetto all'uso di una goroutine per canale.

func merge(a, b <-chan int) <-chan int {
    out := make(chan int)
    go func() {
        defer close(out)
        for a != nil || b != nil {
            select {
            case v, ok := <-a: if !ok { a = nil } else { out <- v }
            case v, ok := <-b: if !ok { b = nil } else { out <- v }
            }
        }
    }()
    return out
}

Fase della pipeline

Combini fan-out e fan-in per creare una fase della pipeline: un canale di input, N worker paralleli e un unico canale di output unificato.

func parallelStage(in <-chan Work, n int) <-chan Result {
    outs := make([]<-chan Result, n)
    for i := 0; i < n; i++ {
        outs[i] = worker(in)
    }
    return fanIn(outs...)
}

Chiudere correttamente i canali

Il mittente chiude il canale; il ricevitore rileva la chiusura tramite la forma di ricezione a due valori o iterando con range. Non chiuda mai dal lato del ricevitore.

for v := range in { // exits when in is closed
    process(v)
}

Coordinamento con WaitGroup

Usi sync.WaitGroup per sapere quando tutti i worker del fan-out hanno terminato, quindi chiuda il canale di output affinché i consumatori a valle possano terminare.

Controllo del flusso

Usi canali con buffer tra le fasi della pipeline per assorbire i picchi. Dimensioni il buffer in base alla differenza di latenza prevista tra produttore e consumatore.

out := make(chan Result, 100) // buffer absorbs bursts

Propagazione degli errori

Inserisca i risultati in una struct che contenga sia il valore sia un errore, così gli errori attraversano la pipeline insieme ai dati senza causare panic.

type Result struct {
    Value int
    Err   error
}

Annullamento tramite context

Passi un context attraverso le fasi della pipeline e controlli ctx.Done() in ogni fase, così l'intera pipeline si arresta quando viene annullata.

case <-ctx.Done():
    return ctx.Err()

Verifica rapida

In un pattern fan-in, che cosa chiude il canale di output unificato?

Riepilogo: fan-in e fan-out

Punti chiave:

Fan-out: più worker leggono da un unico canale
Fan-in: una goroutine per ogni sorgente unisce i valori in un unico canale di output
WaitGroup coordina la chiusura del canale unificato
Usi context per l'annullamento e canali con buffer per il controllo del flusso

Domande Frequenti

La lezione «Modelli fan-in e fan-out» è gratuita?

Sì — il testo completo di «Modelli fan-in e fan-out» è gratuito qui sul web. Per esercitarvi in modo interattivo (un editor di codice integrato e un tutor IA 24/7) e sbloccare il resto del corso Go Academy, passa a CoddyKit PRO. Il corso Go Academy include 4 lezioni in totale.

Cosa imparerò in «Modelli fan-in e fan-out»?

Unire più canali e distribuire il lavoro Eserciti Go Academy con codice pratico che esegui direttamente nel browser, e un tutor IA 24/7 risponde alle tue domande mentre lavori sulla lezione.

Ho bisogno di esperienza per iniziare Go Academy?

Non è richiesta alcuna esperienza precedente. Go Academy su CoddyKit è strutturato per principianti e studenti avanzati, quindi puoi iniziare da qui o dall'inizio e procedere al tuo ritmo. Questa è la lezione 3 di 4.

Quanto tempo richiede la lezione «Modelli fan-in e fan-out»?

La maggior parte delle lezioni CoddyKit richiede circa 5–10 minuti. Ogni lezione è breve e interattiva, quindi fai progressi costanti e riprendi esattamente da dove hai lasciato su web e app.

Posso scrivere ed eseguire codice in questa lezione Go Academy?

Sì. Ogni lezione Go Academy include un editor di codice integrato, quindi scrivi ed esegui codice reale direttamente nel tuo browser e ricevi feedback istantaneo dall'IA — nessuna configurazione locale necessaria.

Tutte le lezioni di questo corso

← Torna a Go Academy