ゴルーチン: 軽量の並列処理

ゴルーチン は、Go によって管理される同時実行の単位です。 ランタイム。関数の前に go キーワードを付けて起動します。 電話:

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

go ステートメントは 即時 を返します。ゴルーチンは で開始されます。 並行して、呼び出し側は続行します。

なぜ「軽い」のか

• 初期スタック ~2KB (必要に応じて最大数百 MB まで動的に増加します)。
• ランタイムによって少数の OS スレッドに 多重化されます (GOMAXPROCS)。
• 数千/数百万のゴルーチンは日常的なものです。 OS スレッドではそれは不可能です。

概念的には、これは「同時ファイアアンドフォーゲット」ですが、 調整するための慣用的なツール (チャネル、sync.WaitGroup、 context)。

メインは待ちません

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

main が返されると、プロセスは終了します。ゴルーチンは取得されません。 「仕事を終える」ために、彼らはただ一緒に殺されるだけです。 プロセス。明示的な同期が必要です。

同期: プレビュー

次のレッスンで説明する 3 つのツール:

// 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

「古典的な」ループ内クロージャのバグ

Go 1.21 まで、これはよくある問題でした。

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

Go 1.22 から、for 変数がそれぞれの環境で新たに作成されます。 反復するため、バグはデフォルトで修正されます。古いコードベースでは、 まだ修正パターンが表示されます。

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 != OS スレッド

単一の OS スレッドで多数のゴルーチンをホストできます。ランタイムが動く 必要に応じてスレッド間でゴルーチンを実行します。

試してみてください

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

要約

• go f() は f() を同時に起動します。すぐに戻ってきます。
• Goroutine = 初期サイズは約 2 KB、いくつかの OS スレッドに多重化されます。
• main は待機しません。同期 (チャネル/待機グループ/コンテキスト) が必要です。
• time.Sleep は単なる教訓であり、運用環境での同期には決して使用されません。
• Go 1.22 以降、for 変数は反復ごとに「最新」になります (「3 3 3」バグはなくなりました)。