Table des matières
Principes et pratique de la communication par fonction et canal en langage Go
Maison développement back-end Golang Le principe de la fonction Golang et de la communication pipeline

Le principe de la fonction Golang et de la communication pipeline

May 04, 2024 pm 06:36 PM
golang 管道 作用域

Les fonctions et les tuyaux du langage Go sont utilisés ensemble pour réaliser une communication inter-processus. Les fonctions peuvent transmettre des tubes en tant que paramètres pour envoyer ou recevoir des données via des tubes. Les tuyaux sont des canaux sans tampon qui peuvent être utilisés pour envoyer et recevoir des données entre des goroutines et prendre en charge les tuyaux non dirigés et dirigés. L'opérateur

Le principe de la fonction Golang et de la communication pipeline

Principes et pratique de la communication par fonction et canal en langage Go

Introduction

La fonction et le canal sont des outils puissants pour la communication inter-processus (IPC) en langage Go. Cet article expliquera leur fonctionnement et fournira des exemples pratiques montrant comment communiquer en les utilisant.

Function

Function est un citoyen de première classe en langage Go, qui peut transmettre des données en tant que paramètres et renvoyer des résultats. Lorsqu'un goroutine (thread léger) appelle une fonction, la fonction s'exécute dans la portée du goroutine. Les variables et les ressources peuvent être transmises entre les appels de fonction.

1

2

3

4

5

6

7

8

func add(x, y int) int {

    return x + y

}

 

func main() {

    result := add(10, 20)

    fmt.Println(result) // 输出:30

}

Copier après la connexion

Pipelines

Les pipelines sont des canaux sans tampon utilisés pour envoyer et recevoir des données entre goroutines. Les tuyaux peuvent être non dirigés ou dirigés. Les tuyaux non dirigés permettent aux données d'être envoyées dans les deux sens entre deux goroutines, tandis que les tuyaux dirigés permettent uniquement un flux de données unidirectionnel.

1

2

3

4

5

// 无向管道

unbufferedChan := make(chan int)

 

// 有向管道

bufferedChan := make(chan int, 10) // 缓冲区大小为 10

Copier après la connexion

Communication entre fonctions et tuyaux

Les fonctions et les tuyaux peuvent être utilisés ensemble pour la communication inter-processus. En passant un tube en tant que paramètre de fonction, une fonction peut envoyer ou recevoir des données via un tube.

Envoi de données

Pour envoyer des données vers un tube, vous pouvez utiliser l'opérateur <- (opérateur d'envoi). L'opérateur <- envoie des données à un tube et bloque la goroutine d'envoi jusqu'à ce que les données soient reçues. <- 操作符(发送运算符)。<- 操作符将数据发送到管道,并阻塞发送 goroutine,直到数据被接收。

1

2

3

func sendData(ch chan int) {

    ch <- 100

}

Copier après la connexion

接收数据

要从管道接收数据,可以使用 <- 操作符(接收运算符)。<-

1

2

3

4

func receiveData(ch chan int) {

    data := <-ch

    fmt.Println(data) // 输出:100

}

Copier après la connexion

Recevoir des données

Pour recevoir des données d'un canal, vous pouvez utiliser l'opérateur <- (opérateur de réception). L'opérateur <- reçoit les données d'un tube et bloque la goroutine de réception jusqu'à ce que les données soient disponibles.

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

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

}

Copier après la connexion

Exemple pratique : calculs simultanés dans des pipelines

🎜🎜L'exemple suivant montre comment utiliser des pipelines pour des calculs simultanés : 🎜rrreee🎜Dans cet exemple, nous envoyons une plage au pipeline puis depuis le pipeline dans une autre goroutine Recevez et imprimer des données. Les canaux sans tampon garantissent que les opérations d'envoi et de réception sont synchronisées. Les tuyaux fournissent un mécanisme de communication entre deux goroutines, permettant des calculs simultanés. 🎜

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!

Déclaration de ce site Web
Le contenu de cet article est volontairement contribué par les internautes et les droits d'auteur appartiennent à l'auteur original. Ce site n'assume aucune responsabilité légale correspondante. Si vous trouvez un contenu suspecté de plagiat ou de contrefaçon, veuillez contacter admin@php.cn

Article chaud

Repo: Comment relancer ses coéquipiers
3 Il y a quelques semaines By 尊渡假赌尊渡假赌尊渡假赌
R.E.P.O. Crystals d'énergie expliqués et ce qu'ils font (cristal jaune)
1 Il y a quelques semaines By 尊渡假赌尊渡假赌尊渡假赌
Hello Kitty Island Adventure: Comment obtenir des graines géantes
3 Il y a quelques semaines By 尊渡假赌尊渡假赌尊渡假赌
Combien de temps faut-il pour battre Split Fiction?
3 Il y a quelques semaines By DDD

Article chaud

Repo: Comment relancer ses coéquipiers
3 Il y a quelques semaines By 尊渡假赌尊渡假赌尊渡假赌
R.E.P.O. Crystals d'énergie expliqués et ce qu'ils font (cristal jaune)
1 Il y a quelques semaines By 尊渡假赌尊渡假赌尊渡假赌
Hello Kitty Island Adventure: Comment obtenir des graines géantes
3 Il y a quelques semaines By 尊渡假赌尊渡假赌尊渡假赌
Combien de temps faut-il pour battre Split Fiction?
3 Il y a quelques semaines By DDD

Tags d'article chaud

Bloc-notes++7.3.1

Bloc-notes++7.3.1

Éditeur de code facile à utiliser et gratuit

SublimeText3 version chinoise

SublimeText3 version chinoise

Version chinoise, très simple à utiliser

Envoyer Studio 13.0.1

Envoyer Studio 13.0.1

Puissant environnement de développement intégré PHP

Dreamweaver CS6

Dreamweaver CS6

Outils de développement Web visuel

SublimeText3 version Mac

SublimeText3 version Mac

Logiciel d'édition de code au niveau de Dieu (SublimeText3)

Comment configurer le pool de connexions pour la connexion à la base de données Golang ? Comment configurer le pool de connexions pour la connexion à la base de données Golang ? Jun 06, 2024 am 11:21 AM

Comment configurer le pool de connexions pour la connexion à la base de données Golang ?

Comment lire et écrire des fichiers en toute sécurité avec Golang ? Comment lire et écrire des fichiers en toute sécurité avec Golang ? Jun 06, 2024 pm 05:14 PM

Comment lire et écrire des fichiers en toute sécurité avec Golang ?

Similitudes et différences entre Golang et C++ Similitudes et différences entre Golang et C++ Jun 05, 2024 pm 06:12 PM

Similitudes et différences entre Golang et C++

Quelle est la courbe d'apprentissage de l'architecture du framework Golang ? Quelle est la courbe d'apprentissage de l'architecture du framework Golang ? Jun 05, 2024 pm 06:59 PM

Quelle est la courbe d'apprentissage de l'architecture du framework Golang ?

Comment générer des éléments aléatoires à partir d'une liste dans Golang ? Comment générer des éléments aléatoires à partir d'une liste dans Golang ? Jun 05, 2024 pm 04:28 PM

Comment générer des éléments aléatoires à partir d'une liste dans Golang ?

Comparaison des avantages et des inconvénients du framework Golang Comparaison des avantages et des inconvénients du framework Golang Jun 05, 2024 pm 09:32 PM

Comparaison des avantages et des inconvénients du framework Golang

Quelles sont les meilleures pratiques pour la gestion des erreurs dans le framework Golang ? Quelles sont les meilleures pratiques pour la gestion des erreurs dans le framework Golang ? Jun 05, 2024 pm 10:39 PM

Quelles sont les meilleures pratiques pour la gestion des erreurs dans le framework Golang ?

instructions d'utilisation du document cadre Golang instructions d'utilisation du document cadre Golang Jun 05, 2024 pm 06:04 PM

instructions d'utilisation du document cadre Golang

See all articles