golang 함수와 파이프라인 통신의 원리
- PHPz원래의
- 2024-05-04 18:36:011040검색
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
함수와 파이프 통신
프로세스 간 통신을 위해 함수와 파이프를 함께 사용할 수 있습니다. 파이프를 함수 매개변수로 전달함으로써 함수는 파이프를 통해 데이터를 보내거나 받을 수 있습니다.
데이터 보내기
데이터를 파이프로 보내려면 연산자(보내기 연산자)를 사용할 수 있습니다. <code> 연산자는 데이터를 파이프로 보내고 데이터가 수신될 때까지 전송 고루틴을 차단합니다. <code> 操作符（发送运算符）。<code> 操作符将数据发送到管道，并阻塞发送 goroutine，直到数据被接收。
func sendData(ch chan int) {
ch <- 100
}接收数据
要从管道接收数据，可以使用 操作符（接收运算符）。<code><pre class='brush:go;toolbar:false;'>func receiveData(ch chan int) {
data := <-ch
fmt.Println(data) // 输出：100
}</pre>
데이터 수신
파이프에서 데이터를 수신하려면 연산자(수신 연산자)를 사용할 수 있습니다. <code> 연산자는 파이프에서 데이터를 수신하고 데이터를 사용할 수 있을 때까지 수신 고루틴을 차단합니다. <p><pre class='brush:go;toolbar:false;'>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()
}</pre></p>
<p>실용 예: 파이프라인의 동시 계산</p>🎜🎜다음 예에서는 동시 계산에 파이프라인을 사용하는 방법을 보여줍니다. 🎜rrreee🎜이 예에서는 파이프라인으로 범위를 보낸 다음 다른 고루틴의 파이프라인에서 수신 및 데이터를 인쇄합니다. 버퍼링되지 않은 파이프는 보내기 및 받기 작업이 동기화되도록 합니다. 파이프는 두 고루틴 간의 통신 메커니즘을 제공하여 동시 계산을 가능하게 합니다. 🎜위 내용은 golang 함수와 파이프라인 통신의 원리의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!