如何使用 Go 语言限制并发执行的任务数量，并保证每次最多只执行 40 个任务？

一分耕耘，一分收获！既然打开了这篇文章《如何使用 Go 语言限制并发执行的任务数量，并保证每次最多只执行 40 个任务？》，就坚持看下去吧！文中内容包含等等知识点...希望你能在阅读本文后，能真真实实学到知识或者帮你解决心中的疑惑，也欢迎大佬或者新人朋友们多留言评论，多给建议！谢谢！

使用 go 限制并发执行的任务

如何在 go 中并发执行任务，同时控制并发数量是一个常见的问题。这个问题要求限制并发执行 100 个任务的数量，每次最多只执行 40 个。

协程池解决方案

一个可行的解决方案是使用协程池。协程池是一个预分配协程集合，可以用来并行执行任务。go 标准库中没有直接提供协程池，但是有很多第三方库可以实现这个功能。

非协程池解决方案

如果你不想使用第三方协程池，也可以通过使用通道和同步原语来实现类似的功能。以下是一个示例代码：

package main

import (
    "fmt"
    "sync"
)

func main() {
    max := 40    // 最大协程数量限制
    tasks := 100 // 任务数量
    wg := sync.WaitGroup{}
    ch := make(chan struct{}, max)
    for i := 0; i < tasks; i++ {
        wg.Add(1)        // 添加计数
        ch <- struct{}{} // 写一个标记到 chan，chan缓存满时会阻塞
        go func(j int) {
            defer func() {
                wg.Done() // 将计数减1
                <-ch      // 读取chan
            }()

            fmt.Println(j)

        }(i)
    }
    wg.Wait() // 等待加入的协程全部完成
    fmt.Println("done...")
}

在这个例子中：

• max: 指定并发协程的最大数量。
• tasks: 指定要执行的任务总数。
• wg: 等待组，用于跟踪正在运行的协程数。
• ch：一个容量为 max 的通道，用于限制并发协程数量。

程序的工作原理如下：

1. 主协程创建 ch 通道并设置容量为 max。
2. 主协程循环创建任务，每个任务都用一个独立的协程运行。
3. 在创建每个任务时，主协程将一个标记写入 ch 通道。
4. 如果 ch 通道已满，发送到 ch 的操作将会被阻塞，直到有空位可用。
5. 每个任务协程完成其任务后，它会从 wg 中减去 1，并从 ch 中读取一个标记。
6. 主协程等待 wg 达到 0，这表示所有任务都已完成。

文中关于的知识介绍，希望对你的学习有所帮助！若是受益匪浅，那就动动鼠标收藏这篇《如何使用 Go 语言限制并发执行的任务数量，并保证每次最多只执行 40 个任务？》文章吧，也可关注golang学习网公众号了解相关技术文章。