在 go 中，并发处理可以通过使用以下方式实现：goroutine： 轻量级线程，使用 go 关键字创建。通道： 通信机制，用于在 goroutine 之间传递数据，并且类型化，只能传输特定类型的数据。通过结合使用 goroutine 和通道，可以实现多消费者并发处理：多个消费者 goroutine 从通道中获取任务。通道提供缓冲，防止 goroutine 因其他 goroutine 而阻塞。
Go 并发处理：使用 Goroutine 和通道
在 Go 编程中，并发处理是充分利用多核 CPU 和提高应用程序性能的关键。以下介绍了使用 Go 中的 Goroutine 和通道来有效处理并发的方式。
Goroutine
立即学习“go语言免费学习笔记（深入）”；
Goroutine 是轻量级的 Go 线程，是并发性的基础。创建 Goroutine 使用 go 关键字后跟一个函数调用。
// 创建一个 Goroutine 来打印字母
go func() {
for {
fmt.Println("a")
}
}()
通道 (Channel)
通道是一种通信机制，用于在 Goroutine 之间安全地传递数据。Go 中的通道是类型化的，这意味着它们只能传输特定类型的数据。
// 创建一个通道来传输字符串 channel := make(chan string)
实战案例：多消费者并发处理
考虑一个需要同时处理大量任务的应用程序。我们可以使用 Goroutine 和通道来并发地处理这些任务，从而提高应用程序的吞吐量。
package main
import (
"fmt"
"time"
)
// 消费者 goroutine，从通道中获取任务并处理
func consumer(tasks <-chan int) {
for task := range tasks {
// 处理任务
fmt.Println("Processed task:", task)
}
}
func main() {
// 创建一个通道来传输任务
tasks := make(chan int, 10) // 缓冲通道，大小为 10
// 创建多个消费者 Goroutine
for i := 0; i < 4; i++ {
go consumer(tasks)
}
// 向通道中添加任务
for i := 0; i < 100; i++ {
tasks <- i
}
// 等待所有任务完成
close(tasks)
time.Sleep(1 * time.Second) // 等待 Goroutine 完成
fmt.Println("All tasks processed")
}
在上面的示例中，consumer Goroutine 从通道中获取任务并处理它们。由于通道是有缓冲的，因此 Goroutine 可以继续从通道中获取任务，而不会因为其他 Goroutine 而被阻塞。
