探索 Go 的 Fan-Out/Fan-In 模式：让并发更 easy
原创 Go Official Blog Go Official Blog 2024-03-29 21:03 中国香港 听全文学习如何利用Go语言的并发性能，使用扇出/扇入模式。探索这种模式如何在 Go 应用程序中简化复杂的并发任务。
Introduction
并发在 Go 中可以是提高程序性能和效率的强大工具。然而，有效管理 goroutine 和 channel 有时可能会有挑战，特别是在复杂的情况下。这就是扇出/扇入模式发挥作用的地方，它使得在 Go 中进行并发更加容易和可维护。
在本文中，我们将探讨扇出/扇入模式，理解其工作原理，并看到如何在 Go 应用程序中使用它的实际示例。
Fan-Out/Fan-In 模式是什么?
扇出/扇入模式是并发编程中常用的设计模式，特别是在 Go 语言中。它包括两个阶段：
- 扇出阶段，在这个阶段，单个 goroutine 将任务广播给多个工作 goroutine；
- 扇入阶段，在这个阶段，这些工作 goroutine 的结果被聚合到一个单一的通道中。
为什么要使用 Fan-Out/Fan-In 模式
扇出/扇入模式通过将复杂的并发任务分解成较小、可管理的部分，简化了任务。它提供了一种结构化的方式来在多个 goroutine 之间分配工作，并高效地收集结果。当有大量任务需要同时执行，并希望确保结果正确聚合时，这种模式尤其有用。
Fan-Out 阶段: 分发 Tasks
在扇出阶段，一个单独的 goroutine（即“主节点”）负责将任务分配给一组工作 goroutine。每个工作 goroutine 并发地处理一部分任务。
以下是Go语言中扇出阶段的示例：
package main
import (
"fmt"
"sync"
"time"
)
func worker(id int, jobs <-chan int, results chan<- int) {
for job := range jobs {
fmt.Printf("Worker %d processing job %d\n", id, job)
// Simulate some work
time.Sleep(time.Millisecond * 500)
results <- job * 2 // Send the result to the results channel
}
}
func main() {
const numJobs = 10
const numWorkers = 3
jobs := make(chan int, numJobs)
results := make(chan int, numJobs)
var wg sync.WaitGroup
// Start workers
for i := 1; i <= numWorkers; i++ {
wg.Add(1)
go func(id int) {
defer wg.Done()
worker(id, jobs, results)
}(i)
}
// Send jobs to workers
for j := 1; j <= numJobs; j++ {
jobs <- j
}
close(jobs)
// Collect results from workers
go func() {
wg.Wait()
close(results)
}()
// Print results
for r := range results {
fmt.Printf("Result: %d\n", r)
}
}
Fan-In 阶段: 收集并处理结果
在 worker 完成任务后，Fan-In 阶段会从所有的 worker 那里收集结果，并将它们汇总到一个 channel 中。这使得就可以轻松地处理合并的结果。
Conclusion
Fan-Out/Fan-In 模式是 Go 中管理并发的有效率工具，它以结构化和高效的方式进行操作。通过将复杂任务划分为更小的单元并汇总结果，你可以充分利用 Go 的并发特性。 在这篇文章中，我们探讨了Fan-Out/Fan-In 模式的基础知识，并看到了它如何应用于实际场景。将这种模式纳入你的 Go 应用程序可以使代码更易读、更易维护，并提高性能。
golang17 Golang27 Go blog 合集27 golang · 目录 上一篇理解 Go 的 FileMode：文件系统操作和权限 阅读 500
- 内容低质
- 不看此公众号内容
- 内容低质
- 不看此公众号内容
- 内容低质
- 不看此公众号内容
人划线
标签：goroutine,模式,并发,Fan,easy,Go,Out From： https://www.cnblogs.com/cheyunhua/p/18105223