在 Goroutine 中等待管道 io.Copy 时发生死锁

在 goroutine 中等待管道 io.copy 时发生死锁

在 Goroutine 中等待管道 io.Copy 时发生死锁是一个常见的问题。当我们在一个 Goroutine 中等待 io.Copy 的完成时,如果管道没有被正确地关闭,就会导致死锁。这种情况下,Goroutine 会一直在等待数据,而无法继续执行下去。解决这个问题的方法是,在 io.Copy 完成后,手动关闭管道,以确保 Goroutine 可以正确结束。php小编苹果为你详细介绍了这个问题的原因和解决方法,希望能帮助你更好地处理这类死锁情况。

问题内容

在下面的代码中,对 io.copy 的调用永远不会返回;它只是无限期地阻塞,导致死锁。仅当使用 io.pipeio.reader 连接到 os.stdout io.writer 时,才会发生此行为。但是,我需要使用管道,因为在我的完整代码中,我使用 io.multiwriterio.pipes 将一个 io.reader 连接到许多需要 io.reader 的函数。

func main() { read := strings.newreader("abcdefghij") pipereader, pipewriter := io.pipe() var wg sync.waitgroup wg.add(1) go func() { println("start copy") _, err := io.copy(os.stdout, pipereader) if err != nil { println(err.error()) } println("end copy") wg.done() }() _, err := io.copy(pipewriter, read) if err != nil { println(err.error()) } wg.wait() }登录后复制