workerpoolpattern-in.go

gistfile1.txt

package processor

import "sync"

type workerPool struct {
	limit chan struct{}
	wg    sync.WaitGroup
}

func (l *workerPool) acquire() {
	l.wg.Add(1)
	l.limit <- struct{}{}
}

func (l *workerPool) wait() {
	l.wg.Wait()
}

func (l *workerPool) release() {
	<-l.limit
	l.wg.Done()
}