golang

golang怎么控制并发数

小亿
157
2023-10-21 15:12:40
栏目: 编程语言

在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来控制并发数了。

0
看了该问题的人还看了