Werfen wir einen Blick auf das Fan-In-Muster. Dies ist in Go wirklich nützlich, wenn wir verwandte Daten aus mehreren Threads haben, die wir zusammenführen müssen.

Angenommen, Sie haben mehrere API-Aufrufe an verschiedene Dienste durchgeführt und müssen die Ergebnisse kombinieren.

Dies ist ein wirklich einfach zu implementierendes Muster, aber Sie müssen darauf achten, wie Sie mit den Kanälen umgehen. Es ist leicht, einen Deadlock-Zustand zu bekommen.

// produce is used to simulate the different data sources
func produce(id int) chan int {
    ch := make(chan int)
    go func() {
        for i := 0; i 



Hier verwenden wir die Produce-Funktion, um die verschiedenen Quellen zu simulieren. Diese Quellkanäle werden an die Fanin-Funktion gesendet, die den Kombinationsvorgang ausführt.

Die Fanin-Funktion erstellt den Ausgabekanal und startet dann eine Goroutine, die jede Eingabe bearbeitet. Wir verwenden eine WaitGroup, um anzugeben, wann alle Eingabequellen im Ausgabekanal kombiniert wurden.

In diesem einfachen Beispiel iteriert der Hauptthread einfach über die Ausgabe. Beachten Sie, dass es keine Garantie für die Reihenfolge gibt, da die Werte der beiden Eingaben gemischt sind. 

Ein wichtiger Punkt, den es zu erwähnen gilt, ist, dass wir den Ausgabekanal schließen müssen, wenn wir mit der Kombination der Eingaben fertig sind. Der Bereichsoperator wartet unbegrenzt, sobald der Kanal leer ist. Kommentieren Sie die Zeile „close(output)“ aus und Sie werden sehen, dass eine Deadlock-Bedingung vorliegt.

Wie können wir das verbessern? Hinterlassen Sie mir unten einen Kommentar.

Danke!

Der Code für diesen Beitrag und alle Beiträge dieser Serie finden Sie hier