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։