Worker pool

worker_pool.go

package main

// Job define job interface
type Job interface {
	Execute()
}

// JobQueue queue of jobs
var JobQueue chan Job

// WorkerNum number of workers
var WorkerNum int

func main() {
	WorkerNum = 100
	JobQueue := make(chan Job, WorkerNum)
	for i := 0; i < WorkerNum; i++ {
		// start a worker
		go func() {
			for {
				job := <-JobQueue
				// do work
				job.Execute()
			}
		}()
	}
	// wait for jobs
	for {
	}
}