파이프라인 통신 구현을 위한 Go 언어 문서의 io.Pipe 기능에 대한 심층적인 이해

func Pipe() (*PipeReader, *PipeWriter)

package main
import (
    "io"
    "fmt"
)

func main() {
    // 创建管道
    reader, writer := io.Pipe()
    
    // 在协程中写入数据
    go func() {
        defer writer.Close()
        writer.Write([]byte("Hello, Pipe!"))
    }()
    
    // 从管道中读取数据
    buf := make([]byte, 128)
    n, err := reader.Read(buf)
    if err != nil {
        fmt.Println("Read error:", err)
        return
    }
    
    fmt.Printf("Read %d bytes: %s
", n, buf[:n])
}

package main
import (
    "io"
    "fmt"
    "time"
)

func main() {
    // 创建管道
    reader, writer := io.Pipe()
    
    // 开启一个协程写入数据
    go func() {
        defer writer.Close()
        
        for i := 0; i < 5; i++ {
            writer.Write([]byte(fmt.Sprintf("Message %d", i)))
            time.Sleep(time.Second)
        }
    }()
    
    // 主协程读取数据
    go func() {
        buf := make([]byte, 128)
        
        for {
            n, err := reader.Read(buf)
            if err != nil {
                fmt.Println("Read error:", err)
                break
            }
            
            fmt.Printf("Read %d bytes: %s
", n, buf[:n])
        }
    }()
    
    // 等待一段时间，观察输出结果
    time.Sleep(time.Second * 10)
}

Read 9 bytes: Message 0
Read 9 bytes: Message 1
Read 9 bytes: Message 2
Read 9 bytes: Message 3
Read 9 bytes: Message 4