Jak určit limit počtu současně spuštěných gorutin v jazyce Go?

V jazyce Go neexistuje vestavěný mechanismus pro přímé omezení počtu současně spuštěných gorutin. Nicméně, pro kontrolu limitu paralelismu se obvykle používají semafory nebo kanály s omezenou kapacitou.

Příklad omezení počtu současně běžících gorutin pomocí kanálu:

package main

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

func worker(id int, sem chan struct{}, wg *sync.WaitGroup) {
    defer wg.Done()
    sem <- struct{}{} // obsadit místo
    fmt.Printf("Goroutine %d začala pracovat\n", id)
    time.Sleep(time.Second) // simulace práce
    fmt.Printf("Goroutine %d dokončila práci\n", id)
    <-sem // uvolnit místo
}

func main() {
    const maxGoroutines = 3
    sem := make(chan struct{}, maxGoroutines) // kanál s bufferem omezuje počet gorutin
    var wg sync.WaitGroup

    for i := 1; i <= 10; i++ {
        wg.Add(1)
        go worker(i, sem, &wg)
    }
    wg.Wait()
}

V tomto příkladu omezuje kanál sem s bufferem maxGoroutines počet současně běžících gorutin. Každá gorutina před začátkem práce vloží do kanálu prázdnou strukturu, čímž obsadí místo, a po dokončení ji uvolní. Tímto způsobem nebude současně pracovat více než maxGoroutines gorutin.