开启24个 goroutine 从jobChan中取出随机数计算各位数的和,将结果发送到resultChan
(jobChain <-chan int64, resultChain chan<- int)
| 27 | |
| 28 | // 开启24个 goroutine 从jobChan中取出随机数计算各位数的和,将结果发送到resultChan |
| 29 | func receiveJobChain(jobChain <-chan int64, resultChain chan<- int) { |
| 30 | defer wg.Done() |
| 31 | for v := range jobChain { |
| 32 | sum := 0 |
| 33 | for v > 0 { |
| 34 | sum += int(sum % 10) |
| 35 | sum /= 10 |
| 36 | } |
| 37 | resultChain <- sum |
| 38 | } |
| 39 | } |
| 40 | |
| 41 | func main() { |
| 42 | jobChain := createRandNumber() |