在Go语言中，由于其内置的并发原语如goroutines和channels，实现并发设计模式如生产者消费者模式和工作池模式变得更加简洁和直观。
生产者消费者模式（使用Go语言）：
// 创建一个带缓冲区的通道，作为共享数据结构
bufferSize := 10
jobs := make(chan int, bufferSize)
// 启动消费者goroutine
go func() {
for job := range jobs {
// 处理任务
process(job)
}
}()
// 在生产者goroutine中生成并发送任务
for i := 0; i < numJobs; i++ {
jobs <- i // 将任务放入通道
}
// 关闭通道以通知消费者所有任务已完成
close(jobs)在这个例子中，生产者通过将任务（整数）发送到jobs通道来生成任务，而消费者则通过从该通道接收任务来处理它们。当所有任务完成后，生产者关闭通道，消费者通过range循环检测到通道关闭并自然退出。
工作池模式（使用Go语言）：
type Worker struct {
JobQueue chan func()
}
func NewWorker(poolSize int) *Worker {
worker := &Worker{
JobQueue: make(chan func(), poolSize),
}
// 启动工作线程
for i := 0; i < poolSize; i++ {
go worker.WorkerFunc()
}
return worker
}
func (w *Worker) WorkerFunc() {
for job := range w.JobQueue {
job() // 执行任务
}
}
func (w *Worker) SubmitJob(job func()) {
w.JobQueue <- job // 提交任务到工作队列
}
// 使用工作池
worker := NewWorker(10) // 创建一个大小为10的工作池
// 提交任务
for i := 0; i < numJobs; i++ {
worker.SubmitJob(func() {
// 这里定义具体的任务逻辑
process(i)
})
}
// 等待所有任务完成（这里没有明确的关闭机制，实际应用中可能需要添加）在这个例子中，我们创建了一个Worker结构体，它包含一个用于存储任务的通道JobQueue。我们启动指定数量的工作线程（每个线程运行WorkerFunc方法），这些线程从JobQueue中取出并执行任务。SubmitJob方法用于将新任务提交到工作队列。这样，我们就实现了一个简单的工作池模式，可以控制并发任务的数量并避免频繁创建和销毁线程的开销。
这两种模式在Go语言中都可以灵活地进行扩展和调整，以适应不同的应用场景和需求。
原文链接: https://www.yukx.com/golang/article/details/2438.html 优科学习网Go并发设计模式：生产者消费者模式、工作池模式等
