Set max concurrent

max_concurrent.go

const maxConcurrency = 10

var throttle = make(chan int, maxConcurrency)
var wg sync.WaitGroup

listGroup = GetList()

for _, e := range listGroup {
		throttle <- 1
		wg.Add(1)
		go pushMessage(&wg, throttle)
}
wg.Wait()



// function
func pushMessage(wg *sync.WaitGroup, throttle chan int) {
	defer wg.Done()
	// TO-DO
	<-throttle
}