Pipeline은 병렬 작업을 생성하는 데 사용할 수 있는 버퍼링되지 않은 통신 메커니즘입니다. 파이프 생성: ch := make(chan int) 데이터 보내기: ch <- i 데이터 수신: for v := range ch { fmt.Println(v ) }
파이프라인은 Go 코루틴 간에 데이터를 전달하는 데 사용되는 버퍼링되지 않은 통신 메커니즘입니다. 파이프를 사용하면 여러 입력 또는 출력을 동시에 처리하는 병렬 작업을 생성할 수 있습니다.
make
함수를 사용하여 파이프를 만들고 보내거나 받을 값 유형을 지정하세요. make
函数创建管道,并指定要发送或接收的值的类型:
var ch chan int ch = make(chan int)
使用 <-
运算符向管道发送数据:
go func() { for i := 1; i <= 5; i++ { ch <- i } }()
使用 <-
for v := range ch { fmt.Println(v) }
<- 사용 code> 연산자 파이프라인으로 데이터 보내기: package main
import (
"fmt"
"time"
)
func main() {
ch := make(chan int)
go func() {
sum := 0
for i := 1; i <= 1000000; i++ {
sum += i
}
ch <- sum
}()
result := <-ch
fmt.Println("The sum is:", result)
}
로그인 후 복사 데이터 받기 <-
연산자를 사용하여 파이프라인에서 데이터 받기: rrreee
실제 예: sum
- 다음 예에서는 방법을 보여줍니다. 파이프라인을 사용하여 병렬 작업 생성하기 여러 숫자의 합을 계산하려면:
rrreee- 이 예에서 코루틴은 합을 계산하여 파이프라인으로 보내는 일을 담당합니다. 메인 코루틴은 파이프로부터 결과를 받아 인쇄합니다.
- 이것은 파이프라인을 사용하여 병렬 작업을 생성하는 간단한 예입니다. 다음과 같은 다양한 시나리오에서 사용할 수 있습니다.
🎜다중 코루틴 처리 데이터 🎜🎜분산 컴퓨팅 🎜🎜이벤트 처리 🎜🎜위 내용은 Go 언어로 파이프라인을 사용하여 병렬 작업을 만드는 방법은 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!