可以通过使用管道实现 go 语言中的非阻塞 i/o：创建无缓冲管道：make(chan int)向管道发送数据：ch
如何使用 Go 语言中的管道进行非阻塞 I/O？
管道是一种在并发 Go 程序中通信的有效方式。它们允许事件式代码，其中每个阶段都独立运行，同时数据在管道中异步流动。本文将展示如何使用管道在 Go 语言中实现非阻塞 I/O。
管道的创建和使用
创建一个管道非常简单：
package main
import "fmt"
func main() {
ch := make(chan int)
}make(chan int) 创建一个可以容纳 int 类型的无缓冲管道。无缓冲意味着数据会立即从一个协程传输到另一个协程，这对于高性能 I/O 应用程序至关重要。
向管道发送数据：
ch <- 1
从管道接收数据：
val := <-ch
实战案例：文件读取
让我们创建一个非阻塞文件读取程序。假设文件内容为：
Hello World
package main
import (
"fmt"
"bufio"
"os"
)
func main() {
ch := make(chan string)
file, err := os.Open("file.txt")
if err != nil {
fmt.Println(err)
return
}
defer file.Close()
go func() {
scanner := bufio.NewScanner(file)
for scanner.Scan() {
ch <- scanner.Text()
}
ch <- "" // 标记文件读完
}()
// 从管道中以非阻塞方式读取行
for {
line := <-ch
if line == "" {
break
}
fmt.Println(line)
}
}该程序创建一个管道用于传输文件行。一个协程负责从文件中读取并向管道发送行。主协程则从管道中接收行，并且由于管道是非阻塞的，所以它可以继续执行其他任务，即使文件读取尚未完成。
当文件读取完成时，发送空行以通知主协程退出循环。
