//package main
//
//import (
//	"fmt"
//	"sync/atomic"
//)
//
//func main() {
//	a := int32(2147483647)
//	l := []string{"k1", "k2", "k3"}
//	atomic.AddInt32(&a, 1)
//	fmt.Printf("a: %+v\n", a)
//	fmt.Printf("a%%5: %+v\n", a%3)
//	fmt.Printf("select :%s", l[a%3])
//}

package main

import (
	"fmt"
	"golang.org/x/sync/errgroup"
	"math/rand"
	"time"
)

func main() {
	ch1 := make(chan int)
	defer close(ch1)
	//ch2 := make(chan int)
	go func() {
		for i := range ch1 {
			fmt.Printf("receive: %d\n", i)
		}
	}()
	time.Sleep(3)
	var eg errgroup.Group
	for i := 0; i < 3; i++ {
		eg.Go(func() error {
			time.Sleep(time.Duration(rand.Intn(2)))

			select {
			case ch1 <- i:
				fmt.Println("send to ch1")
			default:
				fmt.Println("No data received")
			}
			return nil
		})
	}
	_ = eg.Wait()
}