Wie verwalte ich die Parallelität mithilfe von Pipelines in Go?

Pipeline ist ein einfacher Kommunikationsmechanismus, der das Senden und Empfangen von Werten zwischen gleichzeitigen Goroutinen ermöglicht und so die Parallelität und Skalierbarkeit verbessert. So funktioniert eine Pipeline: Eine Pipeline ist eine FIFO-Warteschlange, die aus einem Sender (erstellt mit chan) und einem Empfänger besteht, der <-ch zum Senden bzw. Empfangen von Werten verwendet. Gleichzeitige Verarbeitung mithilfe von Pipes: Aufgaben können parallel verarbeitet werden, indem ein Goroutine-Pool erstellt und Aufgaben mithilfe von Pipes übergeben werden. Praktischer Fall: Das parallele Crawlen von Webseiten kann zeigen, wie Pipelines zum parallelen Crawlen von Webseiten verwendet werden. Fazit: Pipelines sind ein leistungsstarkes Tool zur Verwaltung der Parallelität in Go und zur Verbesserung der Codeleistung, Skalierbarkeit und Wartbarkeit.

Parallelität mithilfe von Pipes in Go verwalten

Pipes sind ein einfacher Kommunikationsmechanismus, der das Senden und Empfangen von Werten zwischen gleichzeitigen Goroutinen in einem Go-Programm ermöglicht. Durch den effektiven Einsatz von Pipelines können Sie die Parallelität und Skalierbarkeit Ihres Codes verbessern.

Wie Pipes funktionieren

Eine Pipeline ist im Wesentlichen eine FIFO-Warteschlange (First In First Out), die zum Übergeben von Werten zwischen Goroutinen verwendet wird. Es besteht aus einem Sendeende und einem Empfangsende. Der Absender wird mit dem Schlüsselwort chan erstellt, wie unten gezeigt: 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()
}

rrreeeUm Werte von a zu empfangen Pipe, verwenden Sie die Syntax &lt ;-ch, wie unten gezeigt: rrreee

Pipes für gleichzeitige Verarbeitung verwenden

Praktischer Fall: Paralleles Crawlen von Webseiten

Das obige ist der detaillierte Inhalt vonWie verwalte ich die Parallelität mithilfe von Pipelines in Go?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!