Давайте посмотрим на схему веера. Это действительно полезно на ходу, когда у нас есть связанные данные из нескольких потоков, которые нам нужно объединить.

Например, предположим, что вы выполнили несколько вызовов API к разным службам и вам необходимо объединить результаты.

Этот шаблон очень легко реализовать, но вам нужно обратить внимание на то, как вы управляете каналами. Легко получить состояние тупика.

// 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 



Здесь мы используем функцию производства для моделирования различных источников. Эти исходные каналы отправляются в функцию fanin, которая выполняет операцию объединения.

Функция fanin создает выходной канал, затем запускает горутину, которая работает с каждым входом. Мы используем WaitGroup, чтобы указать, когда все источники входного сигнала были объединены в выходной канал.

В этом простом примере основной поток просто перебирает выходные данные. Обратите внимание, что нет никаких гарантий относительно заказа, значения из двух входов смешаны. 

Ключевым моментом, который следует отметить, является то, что нам нужно закрыть выходной канал, когда мы закончим объединение входных данных. Оператор диапазона будет ждать бесконечно, как только канал станет пустым. Закомментируйте строку close(output), и вы увидите, что получили состояние взаимоблокировки.

Как мы можем это улучшить? Оставьте мне комментарий ниже.

Спасибо!

Код этого поста и всех постов этой серии можно найти здесь