producers.go

type data struct {
	// ...
}

func main() {
	c := make(chan data)
	defer close(c)
	go saveDataFromChannel(c)

	wg := &sync.WaitGroup{}
	wg.Add(1)
	go getSampleData(c, wg)
	wg.Add(1)
	go getSampleData2(c, wg)
	// ...

	wg.Wait()
}

func getSampleData2(c chan data, wg *sync.WaitGroup) {
	// ...
	c <- data{}
	wg.Done()
}

func getSampleData(c chan data, wg *sync.WaitGroup) {
	// ...
	c <- data{}
	wg.Done()
}

func saveDataFromChannel(c chan data) {
	for d := range c {
		saveDataToMemCache(d)
	}
}

func saveDataToMemCache(d data) {
	// ...
}