example.go

// work performs the actual work by calling the processor and passing in the Job as reference obtained
// from iterating over the "Jobs" channel
func (m *Manager) work(wg *sync.WaitGroup, processor ProcessorFunc) {
    defer wg.Done()
    for job := range m.jobs {
	output := Result{job, processor(job.resource)}
	m.results <- output
    }
}