Sobes.tech
Junior — Middle

Czy możliwe jest ustawienie limitu na liczbę jednocześnie działających wątków w języku Go?

sobes.tech AI

Odpowiedź od AI

W języku Go nie ma wbudowanego mechanizmu bezpośredniego ograniczania liczby jednocześnie działających gorutyn (wątków lekkich). Może być ich bardzo dużo, a są lekkie. Aby ograniczyć liczbę gorutyn działających jednocześnie, zazwyczaj używa się semaforów lub kanałów o ograniczonej pojemności.

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

package main

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

func worker(id int, sem chan struct{}, wg *sync.WaitGroup) {
    defer wg.Done()
    sem <- struct{}{} // Zajmij miejsce
    fmt.Printf("Pracownik %d rozpoczął\n", id)
    time.Sleep(time.Second) // Praca
    fmt.Printf("Pracownik %d zakończył\n", id)
    <-sem // Zwolnij miejsce
}

func main() {
    const maxConcurrent = 3
    sem := make(chan struct{}, maxConcurrent) // Kanał z limitem
    var wg sync.WaitGroup

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

    wg.Wait()
}

Tutaj kanał sem z buforem maxConcurrent ogranicza liczbę gorutyn działających jednocześnie do 3.