當(dāng)我注意到并非管道中的所有關(guān)閉打印都被打印時，我根據(jù)《Go 中的并發(fā)》一書中的示例運行以下代碼?？吹?amp;ldquo;完成倍增！”?不見了。另一方面，NumGoroutine() 顯示僅主函數(shù)正在運行。下面的代碼有什么問題？package mainimport (? ? "fmt"? ? "runtime"? ? "time")func main() {? ? generator := func(done <-chan struct{}) <-chan int {? ? ? ? intStream := make(chan int)? ? ? ? i:=0? ? ? ? go func() {? ? ? ? ? ? defer close(intStream)? ? ? ? ? ? for {? ? ? ? ? ? ? ? select {? ? ? ? ? ? ? ? case <-done:? ? ? ? ? ? ? ? ? ? fmt.Println("done generator!")? ? ? ? ? ? ? ? ? ? return? ? ? ? ? ? ? ? case intStream <- i:? ? ? ? ? ? ? ? ? ? time.Sleep(1 * time.Second)? ? ? ? ? ? ? ? ? ? i++? ? ? ? ? ? ? ? }? ? ? ? ? ? ? ? fmt.Println("generator after select")? ? ? ? ? ? }? ? ? ? }()? ? ? ? return intStream? ? }? ? multiply := func(? ? ? ? done <-chan struct{},? ? ? ? intStream <-chan int,? ? ? ? multiplier int,? ? ) <-chan int {? ? ? ? multipliedStream := make(chan int)? ? ? ? go func() {? ? ? ? ? ? defer close(multipliedStream)? ? ? ? ? ? for i := range intStream {? ? ? ? ? ? ? ? select {? ? ? ? ? ? ? ? case <-done:? ? ? ? ? ? ? ? ? ? fmt.Println("done multiply !")? ? ? ? ? ? ? ? ? ? return? ? ? ? ? ? ? ? case multipliedStream <- i * multiplier:? ? ? ? ? ? ? ? }? ? ? ? ? ? ? ? fmt.Println("multiply after select")? ? ? ? ? ? }? ? ? ? }()? ? ? ? return multipliedStream? ? }? ? add := func(? ? ? ? done <-chan struct{},? ? ? ? intStream <-chan int,? ? ? ? additive int,? ? ) <-chan int {? ? ? ? addedStream := make(chan int)? ? ? ? go func() {? ? ? ? ? ? defer close(addedStream)? ? ? ? ? ? for i := range intStream {? ? ? ? ? ? ? ? select {? ? ? ? ? ? ? ? case <-done:? ? ? ? ? ? ? ? ? ? fmt.Println("done add !")? ? ? ? ? ? ? ? ? ? return? ? ? ? ? ? ? ? case addedStream <- i + additive:? ? ? ? ? ? ? ? }? ? ? ? ? ? ? ? fmt.Println("add after select")? ? ? ? ? ? }? ? ? ? }()? ? ? ? return addedStream? ? }
關(guān)閉完成通道后，goroutine 缺少打印
當(dāng)年話下
2023-08-14 17:00:02
