Comment créer des tâches parallèles à l'aide de pipelines dans Go ?

Pipeline est un mécanisme de communication sans tampon qui peut être utilisé pour créer des tâches parallèles : Créer un canal : ch := make(chan int) Envoyer des données : ch <- i Recevoir des données : for v := range ch { fmt.Println(v ) }

Comment créer des tâches parallèles à l'aide de pipelines en langage Go

Les pipelines sont un mécanisme de communication sans tampon utilisé pour transmettre des données entre les coroutines Go. Les tuyaux peuvent être utilisés pour créer des tâches parallèles afin de traiter plusieurs entrées ou sorties simultanément.

Créer un canal

Utilisez la fonction make pour créer un canal et spécifiez le type de valeur à envoyer ou à recevoir : 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)
}