从接收通道阻塞

Question

我有以下 go 代码来等待流。预期的输出是：line1line2line3line4line5escape1scan donedone....但是之后line5，我的代码一直挂着。var lines = `line1line2line3line4line5line6line7`func main() {    var (        donec  = make(chan struct{})        stream = make(chan string, 5000)        exitc  = make(chan struct{})    )    go func() {        scanner := bufio.NewScanner(strings.NewReader(lines))    escape1:        for {            for scanner.Scan() {                select {                case <-donec:                    fmt.Println("escape1")                    close(stream)                    break escape1                default:                    stream <- scanner.Text()                }            }        }        close(exitc)        fmt.Println("scan done")        return    }()escape2:    for {        select {        case txt, ok := <-stream:            if !ok {                fmt.Println("stream closed!")            }            fmt.Println(txt)            if strings.Contains(txt, "line5") {                close(donec)                <-exitc                break escape2            }        }    }    fmt.Println("done....")}认为我做的一切都是正确的。有人可以帮我调试这个挂起的代码吗？

Answer 1

我认为这是因为您的escape1for 循环包装了for scanner.Scan()循环。

当我删除那个外部 for 循环时，它对我来说很好用：https : //play.golang.org/p/NU3m3Deil7

func main() {

    var (

        donec  = make(chan struct{})

        stream = make(chan string, 5000)

        exitc  = make(chan struct{})

    )

    go func() {

        scanner := bufio.NewScanner(strings.NewReader(lines))

    escape1:

        for scanner.Scan() {

            select {

            case <-donec:

                fmt.Println("escape1")

                close(stream)

                break escape1

            default:

                stream <- scanner.Text()

            }

        }

        close(exitc)

        fmt.Println("scan done")

        return

    }()

escape2:

    for {

        select {

        case txt, ok := <-stream:

            if !ok {

                fmt.Println("stream closed!")

            }

            fmt.Println(txt)

            if strings.Contains(txt, "line5") {

                close(donec)

                <-exitc

                break escape2

            }

        }

    }

    fmt.Println("done....")

}