golang 함수와 파이프라인 통신의 원리

Go 언어의 함수와 파이프는 프로세스 간 통신을 위해 함께 사용됩니다. 함수는 파이프를 매개변수로 전달하여 파이프를 통해 데이터를 보내거나 받을 수 있습니다. 파이프는 고루틴 간에 데이터를 보내고 받는 데 사용할 수 있고 방향이 지정되지 않은 파이프와 방향이 지정된 파이프를 모두 지원하는 데 사용할 수 있는 버퍼링되지 않은 채널입니다.

Go 언어의 함수 및 파이프 통신 원리와 실습

소개

함수와 파이프는 Go 언어의 프로세스 간 통신(IPC)을 위한 강력한 도구입니다. 이 기사에서는 이들의 작동 방식을 자세히 알아보고 이를 사용하여 의사소통하는 방법을 보여주는 실제 사례를 제공합니다.

Function

Function은 Go 언어의 일급 시민입니다. 데이터를 매개변수로 전달하고 결과를 반환할 수 있습니다. 고루틴(경량 스레드)이 함수를 호출하면 해당 함수는 고루틴의 범위 내에서 실행됩니다. 변수와 리소스는 함수 호출 간에 전달될 수 있습니다.

func add(x, y int) int {
    return x + y
}

func main() {
    result := add(10, 20)
    fmt.Println(result) // 输出：30
}

Pipelines

파이프라인은 고루틴 간에 데이터를 보내고 받는 데 사용되는 버퍼링되지 않은 채널입니다. 파이프는 방향이 지정되지 않거나 방향이 지정될 수 있습니다. 방향이 지정되지 않은 파이프를 사용하면 두 고루틴 간에 데이터를 양방향으로 전송할 수 있지만 방향이 지정된 파이프는 단방향 데이터 흐름만 허용합니다.

// 无向管道
unbufferedChan := make(chan int)

// 有向管道
bufferedChan := make(chan int, 10) // 缓冲区大小为 10

함수와 파이프 통신

프로세스 간 통신을 위해 함수와 파이프를 함께 사용할 수 있습니다. 파이프를 함수 매개변수로 전달함으로써 함수는 파이프를 통해 데이터를 보내거나 받을 수 있습니다.

데이터 보내기

데이터를 파이프로 보내려면 <- 연산자(보내기 연산자)를 사용할 수 있습니다. <- 연산자는 데이터를 파이프로 보내고 데이터가 수신될 때까지 전송 고루틴을 차단합니다. <- 操作符（发送运算符）。<- 操作符将数据发送到管道，并阻塞发送 goroutine，直到数据被接收。

func sendData(ch chan int) {
    ch <- 100
}

接收数据

要从管道接收数据，可以使用 <- 操作符（接收运算符）。<-

func receiveData(ch chan int) {
    data := <-ch
    fmt.Println(data) // 输出：100
}

데이터 수신

package main

import (
    "fmt"
    "sync"
)

func main() {
    // 创建无缓冲管道
    ch := make(chan int)
    var wg sync.WaitGroup

    // 创建 goroutine 发送数据到管道
    wg.Add(1)
    go func() {
        defer wg.Done()
        for i := 0; i < 10; i++ {
            ch <- i
        }
        close(ch) // 关闭管道，表示没有更多数据
    }()

    // 创建 goroutine 从管道接收数据
    wg.Add(1)
    go func() {
        defer wg.Done()
        for data := range ch {
            fmt.Println(data)
        }
    }()

    // 等待所有 goroutine 完成
    wg.Wait()
}

실용 예: 파이프라인의 동시 계산

위 내용은 golang 함수와 파이프라인 통신의 원리의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!