Sobes.tech
Junior — Middle

Czy można ustawić limit na liczbę jednocześnie uruchomionych goroutine w programie?

sobes.tech AI

Odpowiedź od AI

W języku Go nie ma wbudowanego mechanizmu do ustawiania sztywnego limitu na liczbę jednocześnie uruchomionych gorutyn. Może ich być bardzo dużo, a planowanie i przełączanie między nimi jest zarządzane przez runtime Go.

Jednak, jeśli chcesz ograniczyć liczbę gorutyn wykonujących się jednocześnie (np. w celu kontroli zużycia zasobów), możesz użyć semaforów lub kanałów do ograniczenia paralelizmu.

Przykład ograniczenia liczby jednocześnie działających gorutyn za pomocą kanału:

package main

import (
    "fmt"
    "sync"
)

func worker(id int, sem chan struct{}, wg *sync.WaitGroup) {
    defer wg.Done()
    sem <- struct{}{} // przejęcie zasobu
    fmt.Printf("Gorutyna %d rozpoczęła pracę\n", id)
    // ... praca ...
    fmt.Printf("Gorutyna %d zakończyła pracę\n", id)
    <-sem // zwolnienie zasobu
}

func main() {
    const maxGoroutines = 5
    sem := make(chan struct{}, maxGoroutines)
    var wg sync.WaitGroup

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

    wg.Wait()
}

W tym przykładzie nie będzie działać więcej niż 5 gorutyn jednocześnie.