Goroutinler: hafif paralellik

goroutine, Go tarafından yönetilen bir eşzamanlı yürütme birimidir çalışma zamanı. Bir işlevin önünde go anahtar sözcüğüyle bir tane başlatırsınız ara:

go greet("Anna")         // chiamata a funzione esistente
go func() {              // funzione anonima
    fmt.Println("hi")
}()

go ifadesi hemen değerini döndürür: goroutine şu şekilde başlar: paraleldir ve arayan kişi devam eder.

Neden "hafif"

• Başlangıç ​​yığını ~2KB (gerekirse yüzlerce MB'a kadar dinamik olarak büyür).
• Çalışma zamanına göre az sayıda işletim sistemi iş parçacığına çoğullanmıştır (GOMAXPROCS).
• Binlerce/milyonlarca goroutin rutindir; işletim sistemi iş parçacıklarıyla bunlar imkansız olurdu.

Kavramsal olarak bu "eşzamanlı ateşle ve unut" yöntemidir, ancak tüm özellikleriyle birlikte koordinasyon için deyimsel araçlar (kanallar, sync.WaitGroup, context).

ana beklemiyor

func main() {
    go func() { fmt.Println("ciao dalla goroutine") }()
    // main esce subito: niente garanzia che la goroutine completi
}

main geri döndüğünde işlem sona erer: goroutinler "işlerini bitirmek" için basitçe öldürülürler süreç. Açık senkronizasyon gerekli.

Senkronizasyon: bir önizleme

Sonraki derslerde göreceğiniz üç araç:

// 1) Channel: la goroutine "segnala" via canale
done := make(chan struct{})
go func() {
    work()
    done <- struct{}{}
}()
<-done   // attendi

// 2) sync.WaitGroup: N goroutine
var wg sync.WaitGroup
wg.Add(1)
go func() { defer wg.Done(); work() }()
wg.Wait()

// 3) context: cancellazione/timeout propagati

"Klasik" döngü içinde kapatma hatası

Go 1.21'e kadar bu sıkça karşılaşılan bir durumdu:

for i := 0; i < 3; i++ {
    go func() { fmt.Println(i) }()  // stampa "3 3 3" su versioni vecchie
}

Go 1.22'den itibaren her birinde for değişkeni yeni oluşturulmuştur. yineleme, böylece hata varsayılan olarak düzeltilir. Daha eski kod tabanlarında şunları yapacaksınız: hala düzeltme modelini görüyorum:

for i := 0; i < 3; i++ {
    i := i           // shadow esplicito
    go func() { fmt.Println(i) }()
}
// oppure passa come argomento:
for i := 0; i < 3; i++ {
    go func(n int) { fmt.Println(n) }(i)
}

Goroutine != İşletim sistemi iş parçacığı

Tek bir işletim sistemi iş parçacığı birçok goroutine ev sahipliği yapabilir. Çalışma zamanı hareketleri Gerektiğinde iş parçacıkları arasında goroutinler.

Deneyin

func main() {
  go work()
  // main ritorna immediatamente
}

Özet

• go f() aynı anda f()'ı başlatır; hemen geri döner.
• Goroutine = ~2 KB başlangıç, birkaç işletim sistemi iş parçacığına çoğullanmış.
• main beklemez: senkronizasyona ihtiyacınız vardır (kanal/WaitGroup/bağlam).
• time.Sleep yalnızca öğreticidir, asla üretimde senkronizasyon için değildir.
• Go 1.22'den itibaren for değişkeni her yinelemede "taze" olur (artık "3 3 3" hatası yoktur).