example.go

// workerPool creates or spawns new "work" goRoutines to process the "Jobs" channel
func (m *Manager) workerPool(processor ProcessorFunc) {
    defer close(m.results)
    var wg sync.WaitGroup
    for i := 0; i < m.numRoutines; i++ {
	wg.Add(1)
	go m.work(&wg, processor)
    }
    wg.Wait()
}