Bufferede channels
Kapacitet, lukning af channels og range over channels
Bufferede channels er en gratis Go Academy-lektion på CoddyKit. Dette er lektion 3 af 4. Du kan læse alle 3 lektioner i dette læringsspor gratis i deres fulde længde — derefter låser CoddyKit PRO alle lektioner op samt praktiske øvelser med en indbygget kodeeditor og en AI-underviser døgnet rundt. Den er en del af læringsforløbet i Go Academy, og dine fremskridt synkroniseres på tværs af nettet og CoddyKit-appen. Go Academy-kurset indeholder 4 lektioner i alt.
Hvad er en bufferet kanal?
En bufferet kanal har en kapacitet — afsendelser blokerer ikke, så længe der er plads i bufferen. Kanalen fungerer som en kø:
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
}Bufferet kanal som kø
Bufferede kanaler implementerer en FIFO-kø mellem goroutines:
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() og cap() på kanaler
Undersøg en bufferet kanals aktuelle størrelse og kapacitet:
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
}Adskillelse af producent og forbruger
En buffer adskiller producentens hastighed fra forbrugerens. Producenten kan komme så mange elementer foran som bufferens størrelse, før den blokerer:
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")
}Semafor med en bufferet kanal
En bufferet kanal med kapaciteten N kan begrænse antallet af samtidige goroutines til N — en simpel semafor:
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()
}Lukning af en bufferet kanal
Når en bufferet kanal lukkes, kan modtagere tømme de resterende bufferede værdier, før de registrerer lukningen:
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
}Bufferet kontra ubufret: Hvornår skal du vælge hvad?
Vejledning til valg:
- Ubufret: garanteret synkron overdragelse, fast rækkefølge, rendezvous-synkronisering
- Bufferet: adskiller producentens og forbrugerens hastigheder, reducerer blokering, implementerer semaforer, indsamler N resultater
- Brug som udgangspunkt ubufret — tilføj kun en buffer, når du kan begrunde størrelsen
- En buffer, der er for lille → blokerer stadig; en, der er for stor → skjuler fejl
Indsamling af resultater med en bufferet kanal
Brug en bufferet kanal til at indsamle resultater fra parallelle goroutines uden blokering:
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) }
}Goroutine-lækage med fuld buffer
Hvis bufferen er fuld, og der ikke findes nogen læser, blokerer afsenderen for evigt — en goroutine-lækage:
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 som bufferet kanal
time.After returnerer en <-chan time.Time med en buffer på 1. Kørselsmiljøet sender til den efter varigheden, hvorefter den indsamles af affaldsopsamleren:
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)
}Hurtigt tjek
Hvad sker der, når du sender til en bufferet kanal, der har nået sin fulde kapacitet?
Opsamling: Bufferede kanaler
Opsummering:
make(chan T, N)opretter en bufferet kanal med kapaciteten N- Afsendelser blokerer kun, når bufferen er fuld; modtagelser blokerer kun, når den er tom
len(ch)— aktuelt antal elementer;cap(ch)— kapacitet- Brug dem til at adskille producenter og forbrugere, indsamle parallelle resultater og implementere semaforer
- Lukning gør det muligt at tømme kanalen før afslutningen;
range chhåndterer dette automatisk
Lær Go med en AI-underviser — gratis
Skriv og kør rigtig kode i din browser, få øjeblikkelig hjælp fra en AI-underviser døgnet rundt, og fortsæt, hvor du slap, på web eller i appen.
- Kurser
- 51
- Lektioner
- 203
Ofte stillede spørgsmål
Er lektionen “Bufferede channels” gratis?
Ja — alle 3 lektioner i læringssporet Go Academy, inklusive “Bufferede channels”, kan læses gratis i deres fulde længde her på webstedet. Derefter låser CoddyKit PRO alle lektioner op samt interaktive øvelser med en indbygget kodeeditor og en AI-underviser døgnet rundt. Go Academy-kurset indeholder 4 lektioner i alt.
Hvad lærer jeg i “Bufferede channels”?
Kapacitet, lukning af channels og range over channels Du øver dig i Go Academy med praktisk kode, som du kører direkte i browseren, og en AI-vejleder døgnet rundt besvarer dine spørgsmål, mens du arbejder dig gennem lektionen.
Skal jeg have erfaring for at begynde på Go Academy?
Der kræves ingen tidligere erfaring. Go Academy på CoddyKit er tilrettelagt for både begyndere og øvede, så du kan starte her eller fra begyndelsen og lære i dit eget tempo. Dette er lektion 3 af 4.
Hvor lang tid tager lektionen “Bufferede channels”?
De fleste CoddyKit-lektioner tager cirka 5–10 minutter. Hver lektion er kort og interaktiv, så du gør løbende fremskridt og kan fortsætte, hvor du slap – på både web og app.
Kan jeg skrive og køre kode i denne Go Academy-lektion?
Ja. Alle Go Academy-lektioner har en indbygget kodeeditor, så du kan skrive og køre rigtig kode direkte i din browser og få øjeblikkelig feedback fra AI – uden lokal opsætning.