Golang 中的 io.PipeWriter.Close() 函数示例

io.PipeWriter.Close() 是 Golang 中管道写入器（PipeWriter）类型的一个方法，用于关闭管道的写入端口。它可以让读取端知道没有更多的数据可读，并且在读取完成后关闭相应的文件描述符，释放相关的资源。

语法

func (pw *PipeWriter) Close() error

示例

下面的示例演示了如何使用 io.PipeWriter.Close() 函数关闭管道的写入端口：

package main

import (
	"fmt"
	"io"
	"os"
)

func main() {
	reader, writer := io.Pipe()

	go func() {
		defer writer.Close()

		// 在这里写入数据到管道
		_, err := writer.Write([]byte("Hello, World!"))
		if err != nil {
			fmt.Println("写入失败：", err)
			return
		}
	}()

	// 在这里从管道读取数据
	data := make([]byte, 12)
	_, err := reader.Read(data)
	if err != nil {
		fmt.Println("读取失败：", err)
		return
	}

	fmt.Println(string(data)) // 输出：Hello, World!
}

在这个例子中，我们通过使用 io.Pipe() 创建了一个新的管道，并使用 go 关键字启动了一个并发的例程来写入数据到管道中。在写入完成后，我们调用了 writer.Close() 来关闭管道的写入端口。

然后主例程继续读取数据，使用 reader.Read() 函数从管道中读取数据。读取成功后，我们将数据转换为字符串并打印出来。

运行这个示例会输出：Hello, World!

结论

io.PipeWriter.Close() 函数用于关闭管道的写入端口。在使用管道时，如果你写入端已经完成写入数据，则应该调用该函数来关闭写入端口，以便读取端知道没有更多的数据可读取。