profiling/blocking/inefficient.go

package blocking

import "time"

var Ch = make(chan int)

func InefficientConsumer() {
	for val := range Ch {
		time.Sleep(time.Second) // slow processing
		println("Received:", val)
	}
}

func InefficientProducer() {
	for i := 0; i < 5; i++ {
		Ch <- i
	}
	close(Ch)
}