Canali bufferizzati
Capacità, chiusura dei canali e range sui canali
Canali bufferizzati è 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'è un canale con buffer?
Un canale con buffer ha una capacità: gli invii non si bloccano finché nel buffer c'è spazio. Il canale si comporta come una coda:
package main
import "fmt"
func main() {
ch := make(chan int, 3) // capacity 3
ch <- 1 // does not block — buffer has room
ch <- 2 // does not block
ch <- 3 // does not block
// ch <- 4 // would block — buffer full
fmt.Println(<-ch) // 1
fmt.Println(<-ch) // 2
fmt.Println(<-ch) // 3
}Canale con buffer come coda
I canali con buffer implementano una coda FIFO tra le goroutine:
package main
import ("fmt"; "sync")
func producer(ch chan<- int, wg *sync.WaitGroup) {
defer wg.Done()
for i := 1; i <= 5; i++ {
ch <- i
fmt.Printf("produced %d\n", i)
}
}
func main() {
ch := make(chan int, 2) // buffer 2 — producer runs ahead
var wg sync.WaitGroup
wg.Add(1)
go producer(ch, &wg)
wg.Wait()
close(ch)
for v := range ch { fmt.Printf("consumed %d\n", v) }
}len() e cap() sui canali
Esamini la dimensione attuale e la capacità di un canale con buffer:
package main
import "fmt"
func main() {
ch := make(chan string, 5)
ch <- "a"
ch <- "b"
ch <- "c"
fmt.Println("cap:", cap(ch)) // 5
fmt.Println("len:", len(ch)) // 3 — items currently buffered
<-ch
fmt.Println("len:", len(ch)) // 2
}Disaccoppiamento tra produttore e consumatore
Un buffer disaccoppia la velocità del produttore da quella del consumatore. Il produttore può procedere in anticipo di un numero di elementi pari alla dimensione del buffer prima di bloccarsi:
package main
import ("fmt"; "sync"; "time")
func produce(ch chan<- int, wg *sync.WaitGroup) {
defer wg.Done()
for i := 0; i < 5; i++ {
ch <- i
}
}
func consume(ch <-chan int, wg *sync.WaitGroup) {
defer wg.Done()
for v := range ch {
time.Sleep(10 * time.Millisecond) // slower consumer
fmt.Println("consumed:", v)
}
}
func main() {
ch := make(chan int, 3)
var wg sync.WaitGroup
wg.Add(2)
go produce(ch, &wg)
go consume(ch, &wg) // BUG: produce closes before consume sees all
// In practice, coordinate close carefully
fmt.Println("decoupled")
}Semaforo con un canale con buffer
Un canale con buffer di capacità N può limitare a N il numero di goroutine concorrenti: è un semplice semaforo:
package main
import ("fmt"; "sync"; "time")
func main() {
sem := make(chan struct{}, 3) // max 3 concurrent
var wg sync.WaitGroup
for i := 0; i < 10; i++ {
wg.Add(1)
i := i
go func() {
defer wg.Done()
sem <- struct{}{} // acquire
defer func() { <-sem }() // release
fmt.Printf("job %d running\n", i)
time.Sleep(50 * time.Millisecond)
}()
}
wg.Wait()
}Chiusura di un canale con buffer
La chiusura di un canale con buffer consente ai ricevitori di svuotare i valori ancora presenti nel buffer prima di rilevare la chiusura:
package main
import "fmt"
func main() {
ch := make(chan int, 5)
for i := 1; i <= 3; i++ { ch <- i }
close(ch)
// Drain all buffered values after close:
for v := range ch {
fmt.Println(v) // 1, 2, 3
}
// range exits after channel closed and drained
}Con buffer o senza buffer: quale scegliere
Guida alla scelta:
- Senza buffer: passaggio sincrono garantito, ordine rigoroso, sincronizzazione tramite rendez-vous
- Con buffer: disaccoppiamento delle velocità di produttore e consumatore, riduzione dei blocchi, implementazione di semafori, raccolta di N risultati
- Per impostazione predefinita scelga un canale senza buffer; aggiunga un buffer solo quando può motivarne la dimensione
- Una dimensione del buffer troppo piccola → il canale continua a bloccarsi; una troppo grande → nasconde i bug
Raccolta dei risultati con un canale con buffer
Utilizzi un canale con buffer per raccogliere i risultati delle goroutine parallele senza blocchi:
package main
import ("fmt"; "sync")
func square(n int) int { return n * n }
func main() {
nums := []int{1, 2, 3, 4, 5}
results := make(chan int, len(nums)) // buffer = goroutine count
var wg sync.WaitGroup
for _, n := range nums {
wg.Add(1)
n := n
go func() {
defer wg.Done()
results <- square(n)
}()
}
wg.Wait()
close(results)
for r := range results { fmt.Println(r) }
}Perdita di goroutine con buffer pieno
Se il buffer è pieno e non esiste alcun lettore, il mittente si blocca per sempre, causando una perdita di goroutine:
package main
import ("fmt"; "time"; "runtime")
func main() {
ch := make(chan int, 2)
// Start goroutine that fills buffer and then blocks
go func() {
ch <- 1
ch <- 2
ch <- 3 // blocks: buffer full, no receiver
fmt.Println("never reached")
}()
time.Sleep(50 * time.Millisecond)
fmt.Println("goroutines:", runtime.NumGoroutine()) // 2 — leaked
}time.After come canale con buffer
time.After restituisce un <-chan time.Time con un buffer di capacità 1. Il runtime vi invia un valore dopo la durata specificata, dopodiché il canale viene raccolto dal garbage collector:
package main
import ("fmt"; "time")
func doWithTimeout(work func() string) (string, bool) {
result := make(chan string, 1)
go func() { result <- work() }()
select {
case r := <-result:
return r, true
case <-time.After(100 * time.Millisecond):
return "", false
}
}
func main() {
r, ok := doWithTimeout(func() string {
time.Sleep(50 * time.Millisecond)
return "done"
})
fmt.Println(r, ok)
}Verifica rapida
Che cosa accade quando si invia a un canale con buffer che ha raggiunto la capacità massima?
Riepilogo: canali con buffer
Riepilogo:
make(chan T, N)crea un canale con buffer di capacità N- Gli invii si bloccano solo quando il buffer è pieno; le ricezioni si bloccano solo quando è vuoto
len(ch)— elementi attuali;cap(ch)— capacità- Utilizzi i canali per disaccoppiare produttori e consumatori, raccogliere risultati paralleli e implementare semafori
- La chiusura consente di svuotare il buffer prima di EOF;
range chgestisce automaticamente questo comportamento
Domande Frequenti
La lezione «Canali bufferizzati» è gratuita?
Sì — il testo completo di «Canali bufferizzati» è 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 «Canali bufferizzati»?
Capacità, chiusura dei canali e range sui canali 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 «Canali bufferizzati»?
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.