Что такое “fan-in” и “fan-out” в Go-конкурентности, и как их использовать для обработки задач?

Question

Fan-out — распределение задач между несколькими воркерами.

Fan-in — объединение результатов из нескольких горутин в один канал.

Используются для параллелизации обработки и агрегации результатов.

YeaHub · Accepted Answer

Fan-out:одна входящая очередь задачмножество воркеров читают задачи параллельнокаждый воркер выполняет обработкуfor i := 0; i < workers; i++ {
    go func() {
        for job := range jobs {
            results <- process(job)
        }
    }()
}Fan-in:несколько источников результатоводин объединяющий каналагрегатор читает все результатыgo func() {
    wg.Wait()
    close(results)
}()Преимущества:равномерная загрузка CPUускорение тяжёлых операцийконтролируемый параллелизмИспользуется в:обработке HTTP задачпарсинге файловмассовых запросах к БД/API