비차단 I/O를 위해 Go에서 파이프를 어떻게 사용하나요?

Go 언어의 비차단 I/O는 파이프를 사용하여 달성할 수 있습니다. 버퍼되지 않은 파이프 만들기: make(chan int) 파이프로 데이터 보내기: ch

비차단 I/O를 위해 Go 언어에서 파이프를 사용하는 방법은 무엇입니까?

파이프는 동시 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)
    }
}

프로그램은 파일 행을 전송하기 위한 파이프를 생성합니다. 코루틴은 파일을 읽고 파이프에 줄을 보내는 일을 담당합니다. 그러면 메인 코루틴은 파이프로부터 라인을 수신하고, 파이프는 비차단형이므로 파일 읽기가 아직 완료되지 않은 경우에도 다른 작업을 계속 수행할 수 있습니다.

파일 읽기가 완료되면 빈 줄을 보내 루프를 종료하도록 메인 코루틴에 알립니다.

위 내용은 비차단 I/O를 위해 Go에서 파이프를 어떻게 사용하나요?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!