taskpool-simple-queue-chan.go

package main

import (
	"os"
	"runtime"
	"strconv"
)

// from https://groups.google.com/forum/#!searchin/golang-nuts/goroutine$20pool/golang-nuts/wnlBR25aFtg/34NAUmZtyA8J
/*
   This function starts off n worker goroutines and allows
you to send work to them.
	In order to close down the work pool, just close the chan that is returned.
*/

type TaskPool struct {
	numThreads int
	work       chan func()
	done       chan bool
}

func NewTaskPool() *TaskPool {
	pool := &TaskPool{}
	return pool
}

func (pool *TaskPool) AddTask(workFunc func()) {
	pool.work <- workFunc
}

func (pool *TaskPool) Start() {
	bindThreads := os.Getenv("OMP_PROC_BIND")
	if bindThreads == "TRUE" {
		runtime.LockOSThread()
	}

	var err error
	pool.numThreads, err = strconv.Atoi(os.Getenv("OMP_NUM_THREADS"))

	if err != nil || pool.numThreads < 1 {
		pool.numThreads = runtime.NumCPU()
	}
	runtime.GOMAXPROCS(pool.numThreads)

	pool.work = make(chan func(), pool.numThreads)
	pool.done = make(chan bool)

	for n := pool.numThreads; n > 0; n-- {
		go func() {
			for x := range pool.work {
				x()
			}
			pool.done <- true
		}()
	}
}

func (pool *TaskPool) Stop() {
	close(pool.work)
	for n := pool.numThreads; n > 0; n-- {
		<-pool.done
	}
}