Risposta

In Go, un canale è un mezzo per trasferire dati tra goroutine con sincronizzazione. Si distingue tra:

• Canale non bufferizzato — blocca il mittente fino a quando i dati non vengono ricevuti da un'altra goroutine.
• Canale bufferizzato — contiene un buffer interno di dimensioni fisse. Il mittente viene bloccato solo se il buffer è pieno.

I canali non bufferizzati sono comodi quando la sincronizzazione è critica e si deve garantire che mittente e ricevente si incontrino nello stesso punto del codice. I bufferizzati sono adatti per il trasferimento di dati "con riserva" — per organizzare code, worker, compiti asincroni.

Esempio:

func main() {
    ch := make(chan int) // non bufferizzato
    go func() {
        ch <- 42 // si blocca finché non c'è un ricevitore
    }()
    fmt.Println(<-ch)

    bufch := make(chan int, 2) // bufferizzato per 2 elementi
    bufch <- 1 // non si blocca
    bufch <- 2 // non si blocca
    // il prossimo invio si bloccherà se non ci sarà lettura
}

Domanda insidiosa

Può un canale bufferizzato fungere da sostituto per una coda tra decine di produttori e consumatori senza ulteriore sincronizzazione?

Spesso si risponde— «sì». In realtà, solo se non è importante garantire l'ordine e i messaggi non vengono persi. Con più lettori/scrittori, possono verificarsi condizioni di race e perdita di dati, quindi è comunque necessario il controllo della sincronizzazione (worker pool, mutex, contesti per chiudere i canali).

Esempi di errori reali a causa della mancanza di conoscenza delle sottigliezze dell'argomento

---

Storia

Nell'elaborazione dei log, i programmatori hanno utilizzato un canale bufferizzato di lunghezza 1000 per trasferire eventi tra il parser e l'aggregatore. Quando il servizio è stato arrestato, hanno dimenticato di chiudere il canale, e parte degli eventi è "andata persa" — i worker hanno terminato prima di elaborare l'intero buffer. È stato corretto chiudendo esplicitamente i canali e bloccando fino a completo svuotamento.

---

Storia

Nel tentativo di sostituire una coda mutex con un canale bufferizzato in un servizio distribuito, non sono state considerate le situazioni di mittenti "bloccati": con il buffer pieno, il blocco del send ha infine rallentato l'intero sistema, causando timeout e l'interfaccia ha cominciato a "laggare". Dopo un'analisi, è stata ripristinata parte della sincronizzazione tramite variabili di condizione.

---

Storia

In un modulo di telemetria, è stato utilizzato un canale non bufferizzato per il log degli errori tra il modulo e il consumatore. A causa di un ritardo casuale nell'elaborazione, il writer si è bloccato, e in un minuto si è accumulata una coda di centinaia di migliaia di dati nelle goroutine — si è verificato un "out of goroutines". È stato corretto sostituendo il canale non bufferizzato con uno bufferizzato e un worker asincrono per svuotare la coda.