DP
Size: a a a
DP
AK
IK
DP
IK
DP
IK
IK
MB
X
X
DP
for i := 0; i < 120; i++ {такое безопасно? у меня такое ощущение, что на самом деле нифига не 120 горутин работает...
go worker(jobs, results)
}
X
func worker(jobs chan string, results chan Results) {да вот исходник воркера, а на запрашиваемой стороне вижу стату что 30 подключений всего
for {
job := <-jobs
ep := strings.Split(job, ":")
// fmt.Println("received job:", job)
result := apiRequest(ep[0], ep[1])
if result.Result == 2 {
log.Println("requeing")
jobs <- job
}
results <- result
runtime.Gosched()
}
}
RK
RK