Comment gérer la simultanéité à l'aide de pipelines dans Go ?

Pipeline est un mécanisme de communication léger qui permet d'envoyer et de recevoir des valeurs entre des goroutines simultanées, améliorant ainsi la concurrence et l'évolutivité. Comment fonctionne un pipeline : Un pipeline est une file d'attente FIFO composée d'un expéditeur (créé à l'aide de chan) et d'un récepteur, qui utilise <-ch pour envoyer et recevoir des valeurs respectivement. Traitement simultané à l'aide de tuyaux : les tâches peuvent être traitées en parallèle en créant un pool de goroutines et en transmettant des tâches à l'aide de tuyaux. Cas pratique : l'exploration parallèle de pages Web peut démontrer comment utiliser des pipelines pour explorer des pages Web en parallèle. Conclusion : les pipelines sont un outil puissant pour gérer la concurrence dans Go, améliorant les performances, l'évolutivité et la maintenabilité du code.

Gérer la simultanéité à l'aide de tuyaux dans Go

Les tuyaux sont un mécanisme de communication léger qui permet d'envoyer et de recevoir des valeurs entre des goroutines concurrentes dans un programme Go. L'utilisation efficace des pipelines peut améliorer la simultanéité et l'évolutivité de votre code.

Comment fonctionnent les tuyaux

Un pipeline est essentiellement une file d'attente FIFO (First In First Out) utilisée pour transmettre des valeurs entre les goroutines. Il se compose d’une extrémité émettrice et d’une extrémité réceptrice. L'expéditeur est créé à l'aide du mot-clé chan, comme indiqué ci-dessous : chan 关键字创建，如下所示：

ch := make(chan int)

接收端可以通过 <-ch 语法接收管道中的值，如下所示：

value := <-ch

发送和接收数据

要将值发送到管道，请使用 <-ch 语法，如下所示：

ch <- value

要从管道接收值，请使用 <-ch

value = <-ch

package main

import (
    "fmt"
    "sync"
    "time"
)

const (
    numWorkers = 4
    numURLs = 100
)

func fetch(url string, ch chan<- string) {
    time.Sleep(time.Second)
    ch <- fmt.Sprintf("Fetched %s", url)
}

func main() {
    var wg sync.WaitGroup
    wg.Add(numWorkers)

    ch := make(chan string)

    for i := 0; i < numWorkers; i++ {
        go func() {
            for url := range ch {
                fetch(url, ch)
            }
            wg.Done()
        }()
    }

    for i := 0; i < numURLs; i++ {
        ch <- fmt.Sprintf("http://example.com/%d", i)
    }
    close(ch)

    wg.Wait()
}

rrreeePour recevoir des valeurs d'un pipe, utilisez la syntaxe &lt ;-ch, comme indiqué ci-dessous : rrreee

Utilisation de pipes pour un traitement simultané

Cas pratique : Exploration parallèle de pages Web

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!