Go Academy · leksjon

Struping av goroutiner

Styr samtidighet

Leksjon 3 av 413 trinn

Struping av goroutiner er en gratis leksjon i Go Academy på CoddyKit. Dette er leksjon 3 av 4. Du kan lese valgfritt 3 leksjoner fra denne læringsstien gratis i sin helhet – deretter låser CoddyKit PRO opp alle leksjoner, samt praktisk øving med en innebygd kodeeditor og en AI-veileder som er tilgjengelig døgnet rundt. Den er en del av læringsløpet i Go Academy, og fremdriften din synkroniseres mellom nettet og CoddyKit-appen. Kurset i Go Academy inneholder totalt 4 leksjoner.

Begrense samtidighet

Noen ganger begrenser du ikke antall per sekund, men hvor mange goroutiner som kjører samtidig. Dette begrenser den samtidige belastningen på en ressurs, uavhengig av tidsberegningen.

  • Begrenser parallellitet
  • Beskytter tilkoblingspooler
  • Forhindrer minnetopper

Semaforkanal

En bufret kanal fungerer som en tellende semafor. Kapasiteten tilsvarer maksimal samtidighet. Når du henter en plass, sender du et token; når du frigjør den, mottar du et token.

sem := make(chan struct{}, 3)

Hent og frigjør

Før arbeidet starter, sender du til kanalen for å hente en plass (handlingen blokkeres hvis kanalen er full). Når arbeidet er ferdig, mottar du fra kanalen for å frigjøre plassen for en annen gorutine.

sem <- struct{}{}        // acquire
// do work
<-sem                    // release

Hvorfor struct{}

En tom struct struct{}{} bruker null byte. Når den brukes som kanalelement, blir semaforen et rent signal uten unødvendig minnebruk.

Begrense en løkke

Start én gorutine per oppgave, men la semaforen styre hver av dem. Høyst cap goroutiner utfører faktisk arbeid samtidig; resten blokkeres ved henting av en plass.

for _, task := range tasks {
    sem <- struct{}{}
    go func(t Task) {
        defer func() { <-sem }()
        process(t)
    }(t)
}

Kombinere med WaitGroup

Semaforen begrenser samtidigheten, men forteller ikke når alt arbeidet er ferdig. Kombiner den med en sync.WaitGroup for å vente på alle oppgavene.

var wg sync.WaitGroup
wg.Add(1)
go func() {
    defer wg.Done()
    defer func() { <-sem }()
    process(t)
}()

Frigjør i defer

Frigjør alltid plassen i en defer, slik at den blir ledig selv om arbeidet utløser en panic eller returnerer tidlig. Hvis du glemmer å frigjøre plassen, lekker den, og nye goroutiner blir til slutt blokkert for alltid.

En komplett kjøring med samtidighetsbegrensning

Dette programmet kjører åtte oppgaver med høyst to samtidige oppgaver, og skriver ut start og slutt for å vise begrensningen i praksis.

package main

import (
    "fmt"
    "sync"
    "time"
)

func main() {
    sem := make(chan struct{}, 2)
    var wg sync.WaitGroup
    for i := 0; i < 8; i++ {
        wg.Add(1)
        sem <- struct{}{}
        go func(id int) {
            defer wg.Done()
            defer func() { <-sem }()
            fmt.Println("start", id)
            time.Sleep(20 * time.Millisecond)
            fmt.Println("end", id)
        }(i)
    }
    wg.Wait()
    fmt.Println("done")
}

errgroup med SetLimit

Pakken golang.org/x/sync/errgroup tilbyr SetLimit for å begrense en gruppe og videreføre den første feilen. Dette er et ryddigere alternativ i mange tilfeller, men pakken er ekstern.

Samtidighetsbegrensning kontra worker-pool

En worker-pool gjenbruker et fast antall goroutiner som henter oppgaver fra en kø. Med en semafor opprettes én gorutine per oppgave, men antallet aktive goroutiner begrenses. Pooler bruker mindre ressurser ved svært mange oppgaver, mens semaforer er enklere å legge til.

Velge grensen

For databasekall bør grensen settes lik eller lavere enn størrelsen på tilkoblingspoolen. For utgående HTTP bør den samsvare med vertens tilkoblingsgrense. En for høy grense kan tømme ressursene; en for lav grense sløser med kapasiteten.

Hurtigsjekk

Test kunnskapene dine om samtidighetsbegrensning.

Oppsummering

Du har lært om begrensning av goroutiner:

  • En bufret kanal fungerer som en tellende semafor
  • Hent en plass ved å sende, og frigjør den ved å motta i defer
  • struct{}-elementer bruker null byte
  • Kombiner med WaitGroup for å vente på at arbeidet blir ferdig
  • Tilpass grensen til ressursen som beskyttes
Gratis å komme i gang

Lær deg Go med en AI-veileder – gratis

Skriv og kjør ekte kode i nettleseren, få umiddelbar hjelp fra en AI-veileder som er tilgjengelig døgnet rundt, og fortsett der du slapp – på nettet eller i appen.

Kurs
51
Leksjoner
203

Ofte stilte spørsmål

Er leksjonen «Struping av goroutiner» gratis?

Ja – du kan lese valgfritt 3 av leksjonene i læringsstien Go Academy, inkludert «Struping av goroutiner», gratis i sin helhet her på nettet. Deretter låser CoddyKit PRO opp alle leksjoner, samt interaktiv øving med en innebygd kodeeditor og en AI-veileder som er tilgjengelig døgnet rundt. Kurset i Go Academy inneholder totalt 4 leksjoner.

Hva lærer jeg i «Struping av goroutiner»?

Styr samtidighet Du øver på Go Academy med praktisk kode som du kjører direkte i nettleseren, mens en AI-veileder som er tilgjengelig døgnet rundt, svarer på spørsmålene dine mens du jobber deg gjennom leksjonen.

Trenger jeg erfaring for å begynne med Go Academy?

Ingen tidligere erfaring er nødvendig. Go Academy på CoddyKit er lagt opp for både nybegynnere og viderekomne, så De kan begynne her eller helt fra start og lære i Deres eget tempo. Dette er leksjon 3 av 4.

Hvor lang tid tar leksjonen «Struping av goroutiner»?

De fleste CoddyKit-leksjoner tar omtrent 5–10 minutter. Hver leksjon er kort og interaktiv, slik at De gjør jevne fremskritt og kan fortsette akkurat der De slapp – både på nettet og i appen.

Kan jeg skrive og kjøre kode i denne Go Academy-leksjonen?

Ja. Alle Go Academy-leksjoner har en innebygd kodeeditor, slik at De kan skrive og kjøre ekte kode direkte i nettleseren og få umiddelbar tilbakemelding fra AI – uten lokal konfigurering.

Alle leksjonene i dette kurset

  1. Token bucket-konseptet
  2. golang.org/x/time/rate
  3. Struping av goroutiner
  4. Tilbakeventing og nye forsøk
← Tilbake til Go Academy