Go Channels：如何使这种非阻塞？

Question

我有一个脚本，它从数据库中选择一些数据并将其发送到一个通道以供多个 goroutine 处理，然后将结果发送回主线程以在数据库上更新。但是，它在将数据发送到第一个通道时挂起（可能阻塞）。频道是在全球范围内创建的：var chin = make(chan in)var chout = make(chan out)in并且out都是structs首先启动goroutines：for i:=0; i<5; i++ {     go worker()}加载通道的代码是：        if verbose {            fmt.Println(`Getting nextbatch2 and sending to workers`)        }        rows, err = nextbatch2.Query()        if err != nil {            panic(err)        }        var numtodo int        for rows.Next() {            err = rows.Scan(&id, &data)            if err != nil {                rows.Close()                panic(err)            }            // Start            var vin in            vin.id = id            vin.data = data            chin <- vin            numtodo++        }        rows.Close()然后紧接着：        if verbose {            fmt.Println(`Processing out channel from workers`)        }        for res := range chout {            update5.Exec(res.data, res.id)            if numtodo--; numtodo == 0 {                break            }        }并且在后台worker()运行多个goroutine：func worker() {      for res := range chin {            var v out            v.id = res.id            v.data = process(res.data)            chout <- v      }}此代码在打印后挂起Getting nextbatch2 and sending to workers。它永远不会到达Processing out channel from workers。所以它挂在rows.Next()循环内的某个地方，我无法弄清楚原因，因为chin通道应该是非阻塞的——即使worker()goroutine 没有处理它，它仍然至少应该完成该循环。有任何想法吗？编辑：通过fmt.Println(" on", numtodo)在rows.Next()循环末尾添加，我可以看到它在 5 之后阻塞，我不明白它应该是非阻塞的，对吧？编辑2：通过将频道更改为make(chan in/out, 100)现在将在 105 之后阻塞。