Sobes.tech
Junior — Middle

Կարո՞ղ է լինել սահմանափակում միաժամանակ աշխատող հոսքերի թվի վրա Go լեզվում։

sobes.tech AI

Պատասխան AI-ից

Go լեզվում չկա ուղիղ սահմանափակող մեխանիզմ միաժամանակ աշխատող գորուտինների (հ Lightweight threads) թվի համար։ Կարող է լինել շատ գորուտին, և դրանք թեթև են։ Միաժամանակ աշխատող գորուտինների թվին սահմանափակում մտցնելու համար սովորաբար օգտագործվում են սեմաֆորներ կամ սահմանափակ ծավալով ալիքներ։

Օրինակ՝ միաժամանակ աշխատող գորուտինների թվին սահմանափակում ալիքով՝

package main

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

func worker(id int, sem chan struct{}, wg *sync.WaitGroup) {
    defer wg.Done()
    sem <- struct{}{} // Արժեք պահել
    fmt.Printf("Աշխատող %d սկսվեց\n", id)
    time.Sleep(time.Second) // Աշխատանք
    fmt.Printf("Աշխատող %d ավարտվեց\n", id)
    <-sem // Արժեք ազատել
}

func main() {
    const maxConcurrent = 3
    sem := make(chan struct{}, maxConcurrent) // Ալիք սահմանափակմամբ
    var wg sync.WaitGroup

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

    wg.Wait()
}

Այստեղ ալիք sem-ը, որի բովանդակությունը maxConcurrent, սահմանափակում է միաժամանակ աշխատող գորուտինների թիվը՝ 3։