pool.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 *Pool) work(wg *sync.WaitGroup, processor ProcessorFunc) {
	defer wg.Done()
	log.DEBUG.Print("goRoutine work starting")
	for job := range m.jobs {
		log.DEBUG.Printf("working on Job ID [%d]", job.id)
		output := Result{job, processor(job.resource)}
		m.results <- output
		log.DEBUG.Printf("done with Job ID [%d]", job.id)
	}
	log.DEBUG.Print("goRoutine work done.")
}