Comment les fonctions Golang utilisent des tuyaux pour communiquer

Dans Go, les pipes sont des files d'attente FIFO utilisées pour la communication entre les goroutines. Créez un pipeline : utilisez la fonction make(chan T), où T est le type de données dans le pipeline. Envoi de données : utilisez la syntaxe ch

Utilisation de pipelines pour la communication des fonctions dans Go

Dans Go, les pipelines sont un mécanisme de communication léger qui permet aux goroutines (coroutines Go) d'échanger des données de manière sûre et efficace. Un canal est essentiellement une file d'attente FIFO (premier entré, premier sorti) à travers laquelle les goroutines peuvent envoyer et recevoir des données.

Créer un pipeline

Le pipeline est créé à l'aide de la fonction make(chan T), où T est le type de données transporté dans le pipeline. L'exemple suivant crée un canal qui contient des données de type chaîne : make(chan T) 函数创建，其中 T 是管道中承载的数据类型。以下示例创建了一个通道，该通道包含字符串类型的数据：

ch := make(chan string)

发送数据

要向管道发送数据，请使用 ch <- data 语法，其中 ch 是要发送数据的管道，而 data 是要发送的值。

ch <- "Hello, World!"

接收数据

要从管道接收数据，请使用 <-ch 语法，其中 ch 是要从中接收数据的管道。

message := <-ch

实战案例：并发文件读取

让我们创建一个使用管道并发的文件读取程序。该程序将从多个文件中读取数据并将其发送到管道，另一个 goroutine 将从管道接收数据并将其打印到控制台。

package main

import (
    "bufio"
    "fmt"
    "io/ioutil"
    "log"
    "os"
)

func readFile(filePath string, ch chan string) {
    file, err := os.Open(filePath)
    if err != nil {
        log.Fatal(err)
    }
    defer file.Close()

    scanner := bufio.NewScanner(file)
    for scanner.Scan() {
        ch <- scanner.Text()
    }
}

func main() {
    ch := make(chan string)

    // 从多个文件中读取数据
    files := []string{"file1.txt", "file2.txt", "file3.txt"}
    for _, file := range files {
        go readFile(file, ch)
    }

    // 从管道接收并打印数据
    for {
        message := <-ch
        if message == "" {
            break
        }
        fmt.Println(message)
    }
}

在这个例子中，我们创建了一个管道 chrrreee

🎜Envoyer des données🎜🎜🎜Pour envoyer des données à un canal, utilisez la syntaxe ch , où <code>ch est le canal auquel envoyer les données et data est la valeur à envoyer. 🎜rrreee🎜🎜Recevoir des données🎜🎜🎜Pour recevoir des données d'un canal, utilisez la syntaxe , où <code>ch est le canal à partir duquel vous souhaitez recevoir des données . 🎜rrreee🎜🎜Cas pratique : lecture simultanée de fichiers🎜🎜🎜Créons un programme de lecture de fichiers qui utilise la concurrence de tubes. Le programme lira les données de plusieurs fichiers et les enverra à un tube, et une autre goroutine recevra les données du tube et les imprimera sur la console. 🎜rrreee🎜Dans cet exemple, nous créons un tube ch qui contiendra les lignes lues dans le fichier. Trois goroutines lisent simultanément les données de différents fichiers et les envoient au tube. Une autre goroutine reçoit les données du canal et les imprime sur la console. 🎜

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!