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

📅  最后修改于: 2021-10-24 13:13:57             🧑  作者: Mango

在 Go 语言中, io包为 I/O 原语提供基本接口。它的主要工作是封装这种原语之王的持续实现。 Go 语言的PipeReader.Close()函数用于关闭阅读器。但是,连续写入PipeWriter,即写入一半的管道将返回 ErrClosedPipe 错误。而且,这个函数是在io包下定义的。在这里,您需要导入“io”包才能使用这些功能。

句法:

func (r *PipeReader) Close() error

这里,“r”是指向 PipeReader 的指针。其中 PipeReader 是管道的读取部分。

返回值:返回调用Close方法前写入的内容。并且连续写入PipeWriter即,写入管道的一半将返回 ErrClosedPipe 错误。

示例 1:

// Golang program to illustrate the usage of
// io.pipeReader.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 Write method in go function
    go func() {
        pipeWriter.Write([]byte("GfG"))
        pipeWriter.Write([]byte("GeeksforGeeks"))
        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 < 2; i++ {
  
        // Reading the contents in buffer
        n, err := pipeReader.Read(buffer)
  
        // If error is not nil panic
        if err != nil {
            panic(err)
        }
  
        // Calling Close method
        pipeReader.Close()
  
        // Prints the content read in buffer
        fmt.Printf("%s\n", buffer[:n])
    }
}

输出:

GfG
panic: io: read/write on closed pipe

goroutine 1 [running]:
main.main()
    /tmp/sandbox180013044/prog.go:38 +0x302

这里,只有一个 Write 操作的内容作为它在 Close() 方法之前写入的内容返回,但在 Close() 方法之后写入的内容没有返回,而是抛出 ErrClosedPipe 错误。

示例 2:

// Golang program to illustrate the usage of
// io.pipeReader.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 Write method in go function
    go func() {
        pipeWriter.Write([]byte("GfG"))
        pipeWriter.Write([]byte("GeeksforGeeks"))
        pipeWriter.Write([]byte("GfG is a CS-Portal."))
    }()
  
    // Creating buffer using make keyword
    // of specified length
    buffer := make([]byte, 50)
  
    // Calling Close method
    pipeReader.Close()
  
    // Using for loop
    for i := 0; i < 2; 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: io: read/write on closed pipe

goroutine 1 [running]:
main.main()
    /tmp/sandbox881512815/prog.go:41 +0x2ea

在这里,在任何读取操作之前调用 Close() 方法时,不会将任何内容读入缓冲区,因此不会读取任何内容,只会在此处抛出错误。