golang怎么控制并发数

在Go中，可以使用goroutine和channel来控制并发数。

首先，可以使用make函数创建一个带有指定并发数的channel。例如，如果要控制并发数为10，可以创建一个大小为10的无缓冲channel：

concurrency := 10
ch := make(chan struct{}, concurrency)

然后，在需要控制并发的地方，在执行每个任务之前，可以向channel发送一个空的struct{}值来占用一个并发槽，表示一个并发任务的启动。当任务完成后，从channel接收一个值来释放一个并发槽。

ch <- struct{}{} // 占用一个并发槽
go func() {
    defer func() { <-ch }() // 释放一个并发槽
    // 执行并发任务的代码
}()

这样就能够通过控制channel的发送和接收来控制并发数了。

完整示例代码如下：

package main

import (
    "fmt"
    "time"
)

func main() {
    concurrency := 10
    ch := make(chan struct{}, concurrency)

    tasks := []string{"task1", "task2", "task3", "task4", "task5", "task6", "task7", "task8", "task9", "task10"}

    for _, task := range tasks {
        ch <- struct{}{} // 占用一个并发槽
        go func(t string) {
            defer func() { <-ch }() // 释放一个并发槽
            fmt.Printf("开始执行任务：%s\n", t)
            time.Sleep(time.Second) // 模拟任务的耗时
            fmt.Printf("任务：%s 执行完成\n", t)
        }(task)
    }

    // 等待所有任务完成
    for i := 0; i < concurrency; i++ {
        ch <- struct{}{}
    }
}

在上面的示例中，我们创建了一个包含10个并发槽的channel，然后使用goroutine来执行任务。在每个任务开始和结束时，我们输出相应的日志。最后，我们使用一个for循环来等待所有任务完成。

注意，为了确保所有的goroutine都能够执行完毕，我们在最后的for循环中再次向channel发送了10个空的struct{}值，以确保释放所有的并发槽。

这样就能够通过channel来控制并发数了。