November 2017
Intermediate to advanced
670 pages
17h 35m
English
At the end of our GenerateCars function, we execute another anonymous Goroutine. The purpose of this Goroutine is to wait for all the previously launched Goroutine generators to complete. We use waitGroup.Wait to know when the last generator was completed. Then, it's safe to close carChannel:
go func() { waitGroup.Wait() println("close channel") close(carChannel) }() for thisCar := range carChannel { generatedCars = append(generatedCars, thisCar.Car) } return generatedCars}
The carChannel will block until it receives a new car; this is a result of calling GetThisCar(carIndex). Recall that WaitGroup.Add(numCarsToGenerate) told WaitGroup how many cars we'd process. The waitGroup.Done() function counts ...