在 Goroutine 中等待管道 io.Copy 时发生死锁
Feb 15, 2024 pm 03:10 PM在 Goroutine 中等待管道 io.Copy 时发生死锁是一个常见的问题。当我们在一个 Goroutine 中等待 io.Copy 的完成时,如果管道没有被正确地关闭,就会导致死锁。这种情况下,Goroutine 会一直在等待数据,而无法继续执行下去。解决这个问题的方法是,在 io.Copy 完成后,手动关闭管道,以确保 Goroutine 可以正确结束。php小编苹果为你详细介绍了这个问题的原因和解决方法,希望能帮助你更好地处理这类死锁情况。
问题内容
在下面的代码中,对 io.copy
的调用永远不会返回;它只是无限期地阻塞,导致死锁。仅当使用 io.pipe
将 io.reader
连接到 os.stdout
io.writer
时,才会发生此行为。但是,我需要使用管道,因为在我的完整代码中,我使用 io.multiwriter
和 io.pipe
s 将一个 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() }
登录后复制
输出:
Start copy abcdefghij fatal error: all goroutines are asleep - deadlock! goroutine 1 [semacquire]: sync.runtime_Semacquire(0xc0000b0018?) /usr/local/go-faketime/src/runtime/sema.go:62 +0x25 sync.(*WaitGroup).Wait(0x4969c8?) /usr/local/go-faketime/src/sync/waitgroup.go:139 +0x52 main.main() /tmp/sandbox4108076976/prog.go:31 +0x23c goroutine 18 [select]: io.(*pipe).read(0xc0000a6120, {0xc0000b6000, 0x8000, 0xc00009e101?}) /usr/local/go-faketime/src/io/pipe.go:57 +0xb1 io.(*PipeReader).Read(0x10?, {0xc0000b6000?, 0xc00009e1e0?, 0x4f75a0?}) /usr/local/go-faketime/src/io/pipe.go:136 +0x25 io.copyBuffer({0x496aa8, 0xc00009e1e0}, {0x4969a8, 0xc0000a4018}, {0x0, 0x0, 0x0}) /usr/local/go-faketime/src/io/io.go:427 +0x1b2 io.Copy(...) /usr/local/go-faketime/src/io/io.go:386 os.genericReadFrom(0xb000000006018ab?, {0x4969a8, 0xc0000a4018}) /usr/local/go-faketime/src/os/file.go:162 +0x67 os.(*File).ReadFrom(0xc0000a4008, {0x4969a8, 0xc0000a4018}) /usr/local/go-faketime/src/os/file.go:156 +0x1b0 io.copyBuffer({0x496a28, 0xc0000a4008}, {0x4969a8, 0xc0000a4018}, {0x0, 0x0, 0x0}) /usr/local/go-faketime/src/io/io.go:413 +0x14b io.Copy(...) /usr/local/go-faketime/src/io/io.go:386 main.main.func1() /tmp/sandbox4108076976/prog.go:18 +0x71 created by main.main /tmp/sandbox4108076976/prog.go:16 +0x1d3
登录后复制
这里是代码的游乐场链接:https://goplay.tools/snippet/70ubgiz8ftv
有没有办法在保留 io.pipe
的同时避免死锁?
解决方法
完成后关闭管道的写入端:
_, err := io.Copy(pipeWriter, read) pipeWriter.Close() if err != nil { println(err.Error()) }
登录后复制
否则,读者端将无限期地等待。
以上是在 Goroutine 中等待管道 io.Copy 时发生死锁的详细内容。更多信息请关注PHP中文网其他相关文章!
本站声明
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

热门文章
击败分裂小说需要多长时间?
3 周前
By DDD
仓库:如何复兴队友
3 周前
By 尊渡假赌尊渡假赌尊渡假赌
Hello Kitty Island冒险:如何获得巨型种子
3 周前
By 尊渡假赌尊渡假赌尊渡假赌
R.E.P.O.能量晶体解释及其做什么(黄色晶体)
1 周前
By 尊渡假赌尊渡假赌尊渡假赌
公众号网页更新缓存难题:如何避免版本更新后旧缓存影响用户体验?
3 周前
By 王林

热门文章
击败分裂小说需要多长时间?
3 周前
By DDD
仓库:如何复兴队友
3 周前
By 尊渡假赌尊渡假赌尊渡假赌
Hello Kitty Island冒险:如何获得巨型种子
3 周前
By 尊渡假赌尊渡假赌尊渡假赌
R.E.P.O.能量晶体解释及其做什么(黄色晶体)
1 周前
By 尊渡假赌尊渡假赌尊渡假赌
公众号网页更新缓存难题:如何避免版本更新后旧缓存影响用户体验?
3 周前
By 王林

热门文章标签

记事本++7.3.1
好用且免费的代码编辑器

SublimeText3汉化版
中文版,非常好用

禅工作室 13.0.1
功能强大的PHP集成开发环境

Dreamweaver CS6
视觉化网页开发工具

SublimeText3 Mac版
神级代码编辑软件(SublimeText3)