Buntu semasa menunggu paip io.Salin dalam Goroutine

Kebuntuan apabila menunggu talian paip io.Salin dalam Goroutine adalah masalah biasa. Apabila kita menunggu siap io.Copy dalam Goroutine, jika paip tidak ditutup dengan betul, ia akan menyebabkan kebuntuan. Dalam kes ini, Goroutine akan terus menunggu data dan tidak boleh meneruskan pelaksanaan. Penyelesaian kepada masalah ini adalah dengan menutup paip secara manual selepas io.Copy selesai untuk memastikan bahawa Goroutine boleh berakhir dengan betul. Editor PHP Apple telah memperkenalkan punca dan penyelesaian kepada masalah ini secara terperinci, dengan harapan dapat membantu anda menangani situasi kebuntuan jenis ini dengan lebih baik.

Kandungan soalan

Dalam kod di bawah, fungsi untuk io.copy 的调用永远不会返回；它只是无限期地阻塞，导致死锁。仅当使用 io.pipe 将 io.reader 连接到 os.stdout io.writer 时，才会发生此行为。但是，我需要使用管道，因为在我的完整代码中，我使用 io.multiwriter 和 io.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()
}

Keluaran:

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

Berikut ialah pautan taman permainan kepada kod: https://goplay.tools/snippet/70ubgiz8ftv

Adakah cara untuk mengelakkan kebuntuan semasa mengawet io.pipe?

Penyelesaian

Tutup hujung tulisan paip apabila selesai:

_, err := io.Copy(pipeWriter, read)
pipeWriter.Close()
if err != nil {
    println(err.Error())
}

Jika tidak, pembaca akan menunggu selama-lamanya.

Atas ialah kandungan terperinci Buntu semasa menunggu paip io.Salin dalam Goroutine. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!