Golang 函数的 Goroutine 调度与并发

在 golang 中，使用 goroutine 实现函数的并发涉及以下步骤：创建 goroutine：使用 go 关键字执行函数或函数调用，例如：go func() { // goroutine 中的代码 }()。调度策略：golang 使用合作式和抢占式调度策略，允许 goroutine 交替执行。并发函数：创建一个包含多个 goroutine 的函数，使其同时执行。结果汇总：使用通道来接收和汇总 goroutine 返回的结果。

Golang 函数的 Goroutine 调度与并发

在 Golang 中，Goroutine 是轻量级线程，允许在同一应用程序中执行并发任务。Goroutine 的调度由 runtime 管理，本文将探讨在函数中使用 Goroutine 执行并发任务的策略。

Goroutine 创建

使用 go 关键字可以创建 Goroutine，该关键字后跟一个函数字面量或函数调用。例如：

func main() {
    go func() {
        // goroutine 中执行的代码
    }()
}

调度策略

Golang 的 runtime 使用以下策略调度 Goroutine：

• 合作式调度：Goroutine 协作让出执行权给其他 Goroutine，通过 yield 函数或在 I/O 操作期间让出执行权。
• 抢占式调度：对于某些类型的操作（如系统调用），runtime 会强制抢占 Goroutine 的执行权，以确保系统的响应能力。

并发函数

要创建并发函数，可以在函数中创建多个 Goroutine 并让它们同时执行。例如：

func doSomethingInParallel(requests []Request) {
    resultCh := make(chan Result, len(requests))

    // 为每个请求创建一个 Goroutine
    for _, request := range requests {
        go func(req Request) {
            // 处理请求并向结果通道发送结果
            result := doSomething(req)
            resultCh <- result
        }(request)
    }

    // 接收并汇总结果
    results := []Result{}
    for i := 0; i < len(requests); i++ {
        results = append(results, <-resultCh)
    }
}

在这个例子中，doSomethingInParallel 函数创建了一个 Goroutine 池来同时处理请求。结果通过一个通道汇总，该通道将每个 Goroutine 产生的结果发送到主函数。

实战案例

以下是一个使用函数级别并发处理图像文件大小的实战案例：

func resizeImagesInParallel(imagePaths []string) {
    resizedPathsCh := make(chan string, len(imagePaths))

    // 为每个图像创建 Goroutine
    for _, imagePath := range imagePaths {
        go func(path string) {
            // 调整图像大小并将路径发送到结果通道
            resizedPath := resizeImage(path)
            resizedPathsCh <- resizedPath
        }(imagePath)
    }

    // 接收并打印已调整图像的大小路径
    for i := 0; i < len(imagePaths); i++ {
        fmt.Println("Resized:", <-resizedPathsCh)
    }
}

此函数在单独的 Goroutine 中异步调整图像大小，并打印已调整图像的路径。它提高了图像调整的效率，尤其是在图像数量较多或图像文件较大时。

以上就是Golang 函数的 Goroutine 调度与并发的详细内容，更多请关注其它相关文章！