可以通过使用管道实现 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)
    }
}

该程序创建一个管道用于传输文件行。一个协程负责从文件中读取并向管道发送行。主协程则从管道中接收行，并且由于管道是非阻塞的，所以它可以继续执行其他任务，即使文件读取尚未完成。

当文件读取完成时，发送空行以通知主协程退出循环。