go 例程被阻止

“纵有疾风来，人生不言弃”，这句话送给正在学习Golang的朋友们，也希望在阅读本文《go 例程被阻止》后，能够真的帮助到大家。我也会在后续的文章中，陆续更新Golang相关的技术文章，有好的建议欢迎大家在评论留言，非常感谢！

我倾向于继续，所以这可能是一个愚蠢的问题。

我似乎无法弄清楚为什么我的一个 go 例程被另一个例程阻止。我的理解（可能是错误的）go 例程作为独立的轻量级线程运行，因此它们不应该互相阻塞，除非我搞砸了:)

我已经粘贴了下面的代码，希望得到任何帮助/提示来解决这个问题。

package main
import "fmt"
import "time"
import "sync"



func worker( jobs <-chan int, job2 chan<- int) {
    defer wg.done()
    for j := range jobs {
        fmt.println("finished job", j)
        time.sleep(time.second/2)

        if(j%3==0){
           job2 <- j   
        }  

   } 
   close(job2)
   fmt.println("channel job2 closed")
 }

func worker2(job2 <-chan int) {
    defer wg.done()
    for i:= range job2 {
        fmt.println(i)
        time.sleep(time.second*10)
    } 
}

var wg sync.waitgroup

func main() {

    wg.add(2)
    jobs := make(chan int)

    job2 := make(chan int)

    go func() {
        for j := 1; j <= 10; j++ {
             jobs <- j
        }
        close(jobs)
        fmt.println("channel jobs closed")
    }()

    go worker(jobs,job2)
    go worker2(job2)

    wg.wait()
    fmt.println("exiting main")     

}

运行此代码时得到以下输出

finished job 1
finished job 2
finished job 3
finished job 4
3
finished job 5
finished job 6
6
finished job 7
finished job 8
finished job 9
9
finished job 10
channel jobs closed
channel job2 closed
exiting main

但是我期待这样的事情？

finished job 1
finished job 2
finished job 3
finished job 4
3
finished job 5
finished job 6
finished job 7
finished job 8
finished job 9
finished job 10
channel jobs closed
6
9    
channel job2 closed
exiting main

解决方案

您的例程有点阻塞，因为通道没有缓冲。无缓冲通道上的写入/读取是阻塞操作。因此，根据定义，您的例程必须互相等待。

本质上，你的半秒睡眠是无关紧要的，因为第二个工作人员睡眠了 10 秒。这 10 秒将阻止对第二个通道的读/写。向通道添加一个缓冲区来解决这个问题。

我想指出的其他一些事情是：

• time.Sleep(time.Second/2) 不起作用（嗯，它是，但除以 3 例如不行）。 time.Sleep 需要 time.Duration 参数，该参数是 int64。您需要传递类似 time.Millisecond * 500 的内容
• 将通道传递给例程并从未创建通道的例程中关闭它是一种不好的形式。通道的创建和关闭应包含在单个例程中。如果没有，它可以工作，但维护会变成一场真正的噩梦。
• 对导入进行分组，无需重复 import "package"，只需使用 import ("package1"\n"package2")
• 如果没有必要，不要使用全局变量。在启动所有例程的函数中创建等待组，并将指向它的指针传递给所有例程。包括匿名函数，只是为了安全起见（例如，一旦您开始向通道添加缓冲区）
• 考虑查看 context.Context 和 select 构造。您可以创建 context.WithCancel 并在所有例程中选择侦听 ctx.Done() 。然后，您可以一次性取消所有例程，而无需处理信号并将内容推送到取消通道

演示

我更改了一些内容（主要是频道创建和一些小的代码清理），并创建了一个演示示例 here

以上就是《go 例程被阻止》的详细内容，更多关于的资料请关注golang学习网公众号！