Golang io.PipeWriter.Close() 的使用方法及示例

在Go语言中，io包提供了I/O原语的基本接口，它的主要作用是封装这种原语的正在进行的实现。Go语言中的 PipeWriter.Close() 函数用于关闭写入器。但是，从管道的读取半部分（即PipeReader）连续读取将不会返回任何字节，并且会返回EOF错误。此外，此函数在io包下定义。在使用这些函数之前，您需要导入“io”包。

语法：

func (w * PipeWriter) Close() error

在这里，“w”是指向PipeWriter的指针。其中，PipeWriter是管道的写半部分。

返回值： 它返回在调用Close()方法之前写入的内容。在调用Close()方法后，从管道读取半部分（即PipeReader）连续读取将不会返回任何字节，并且将返回EOF错误。

示例1：

// Golang program to illustrate the usage of
// io.PipeWriter.Close() function
  
// Including main package
package main
  
// Importing fmt and io
import (
    "fmt"
    "io"
)
  
// Calling main
func main() {
  
    // Calling Pipe method
    pipeReader, pipeWriter := io.Pipe()
  
    // Calling Close method in go function after
    // two Write operations
    go func() {
        pipeWriter.Write([]byte("GfG"))
        pipeWriter.Write([]byte("GeeksforGeeks"))
        pipeWriter.Close()
  
        // Again calling Write method
        pipeWriter.Write([]byte("GfG is a CS-Portal."))
    }()
  
    // Creating buffer using make keyword
    // of specified length
    buffer := make([]byte, 50)
  
    // Using for loop
    for i := 0; i < 4; i++ {
  
        // Reading the contents in buffer
        n, err := pipeReader.Read(buffer)
  
        // If error is not nil panic
        if err != nil {
            panic(err)
        }
  
        // Prints the content read in buffer
        fmt.Printf("%s\n", buffer[:n])
    }
} 

输出：

GfG
GeeksforGeeks
panic: EOF

goroutine 1 [running]:
main.main()
    /tmp/sandbox342418232/prog.go:42 +0x2d1

在这里，两个Write操作的内容会按原样返回，因为它们是在Close()方法之前写入的，但在Close()方法之后写入的内容不会被返回，而会抛出EOF错误。

示例2：

// Golang program to illustrate the usage of
// io.PipeWriter.Close() function
  
// Including main package
package main
  
// Importing fmt and io
import (
    "fmt"
    "io"
)
  
// Calling main
func main() {
  
    // Calling Pipe method
    pipeReader, pipeWriter := io.Pipe()
  
    // Calling Close method in go function
    go func() {
        pipeWriter.Close()
  
        // Calling Write method
        pipeWriter.Write([]byte("GfG is a CS-Portal."))
    }()
  
    // Creating buffer using make keyword
    // of specified length
    buffer := make([]byte, 50)
  
    // Using for loop
    for i := 0; i < 4; i++{
      
        // Reading the contents in buffer
        n, err := pipeReader.Read(buffer)
  
        // If error is not nil panic
        if err != nil {
            panic(err)
        }
  
        // Prints the content read in buffer
        fmt.Printf("%s\n", buffer[:n])
    }
} 

输出：

panic: EOF

goroutine 1 [running]:
main.main()
    /tmp/sandbox173042396/prog.go:40 +0x2d1

在这里，在Close() 方法之前没有进行任何Write操作，因此不会返回任何内容，而会抛出EOF错误。