Wie erstelle ich parallele Aufgaben mithilfe von Pipelines in Go?

Pipeline ist ein ungepufferter Kommunikationsmechanismus, der zum Erstellen paralleler Aufgaben verwendet werden kann: Pipe erstellen: ch := make(chan int) Daten senden: ch <- i Daten empfangen: for v := range ch { fmt.Println(v ) }

So erstellen Sie parallele Aufgaben mithilfe von Pipelines in der Go-Sprache

Pipelines sind ein ungepufferter Kommunikationsmechanismus, der zum Übertragen von Daten zwischen Go-Coroutinen verwendet wird. Mit Pipes können parallele Aufgaben erstellt werden, um mehrere Eingaben oder Ausgaben gleichzeitig zu verarbeiten.

Eine Pipe erstellen

Verwenden Sie die Funktion make, um eine Pipe zu erstellen und den Typ des zu sendenden oder zu empfangenden Werts anzugeben: 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)
}

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)
}