课件及源代码地址

老师您好。 传参 chan的时候，指针传参和值传参，看起来好像都可以work，而且复用的还是同一个通道。 那对于chan的值传参，copy的是什么？

package close import ( "fmt" "sync" "testing" ) // 发布者 func publisher(ch chan int) { go func() { for i := 0; i < 10; i++ { ch <- i } }() } // 接受者 func receiver(ch chan int, wg sync.WaitGroup) { go func() { //for { for i := 0; i < 10; i++ { fmt.Println(<-ch) } wg.Done() }() } func TestPubRe(t *testing.T) { var wg sync.WaitGroup ch := make(chan int) publisher(ch) wg.Add(1) receiver(ch, wg) wg.Wait() } 当WaitGroup使用值接收时为什么会报fatal error: all goroutines are asleep - deadlock!; ? 但当我使用指针接收时,就不会抛出deadlock

func dataProducer(ch chan int, wg *sync.WaitGroup) 老师，为什么你只把WaitGroup的指针传进去，而channel不传指针呢？编程(ch *chan int, wg *sync.WaitGroup)?

func serviceOne() string { time.Sleep(time.Millisecond * 50) return "service 1 done" } func channelserviceone_2nd() chan string { retCh := make(chan string, 1) go func() { ret := serviceOne() fmt.Println("returned result.") retCh <- ret fmt.Println("service exited.") }() return retCh } func TestSelect(t *testing.T) { select { case ret := <-channelserviceone_2nd(): t.Log(ret) case <-time.After(time.Millisecond * 49): t.Log("time out") } } Output: === RUN TestSelect returned result. service exited. --- PASS: TestSelect (0.05s) /Users/stevenfung/Documents/code/go/src/github.com/CrazyPassion/go/helloworld/test/goroutine/goroutine_test.go:115: time out PASS ok github.com/CrazyPassion/go/helloworld/test/goroutine 0.058s Success: Tests passed. 老师，请教下这个问题，这个想不明白。按说serviceOne等待是50ms，49ms会超时，觉得应该看不到channelserviceone_2nd里面的打印，但是现在可以看到，并且也看到了超时的打印，这个是为什么？

消费者可以通过 data,ok<-ch 来判断通道是否关闭, 生产者如何判断通道是否关闭? func TestCloseChannel(t *testing.T) { var wg sync.WaitGroup ch := make(chan int) dataProducer(ch, &wg) dataReceiver(ch, &wg) // 已经关闭通道, 生产者如何判断 close(ch) wg.Wait() }

请教老师，go run和go test有什么不同呢？ 我为了实现消费者每隔一秒打印0，1，2...，所以在生产者的协程里加了一个time.Sleep，也就是每隔一秒产生一个数字。IDE的debug模式和go run都能正常实现，但是go test看起来就像把输出缓存起来，然后等最外面额协程执行完，一下子打印所有的输出

本节中的dataProducer方法，waitGroup传入的是指针，为什么在方法体中使用时，不需要像传入int指针一样，写成*wg.Done()

老师，请教一个问题，如果做爬虫程序，其实程序启动就是死循环，初始化channel容量10个，有新数据就添加到channel里，然后一直不关闭，应该也不会有问题吧

func TestCloseChannel(t *testing.T) { var wg sync.WaitGroup ch := make(chan int) wg.Add(1) dataProducer(ch, &wg) wg.Add(1) dataReceiver(ch, &wg) wg.Add(1) dataReceiver(ch, &wg) wg.Add(1) dataReceiver(ch, &wg) wg.Wait() } 想知道，为什么后面的两个 dataReceiver 也能得到数据， 难道这三个dataReceiver不是串行执行的吗？我的理解是第一个 dataReceiver 会把 dataProducer 产生的所有数据都读完 才退出。

老师，当发送操作在执行的时候发现空的通道中，正好有等待的接收操作，那么它会直接把元素值复制给接收方，实际是这样的吗