02_ms_sr.go

package main

import (
	"fmt"
	"sync"
)

func sender(id int, ch chan message, wg *sync.WaitGroup) {
	defer wg.Done()
	for i := 0; i < 3; i++ {
		ch <- message { senderID: id, value: i}
		fmt.Printf("Sender [%d] send: %d\n", id, i)
	}
}

func multiSenderSingleReceiver() {
	ch := make(chan message)
	var wg sync.WaitGroup

	// Multiple sender
	for i := 1; i <= 3; i++ {
		wg.Add(1)
		go sender(i, ch, &wg)
	}
	
	go func ()  {
		wg.Wait()
		close(ch)
	}()
		
	// Single receiver
	for msg := range ch {
		fmt.Printf("Receiver: Value = %d, from Sender [%d]\n", msg.value, msg.senderID)
	}
}