Go 函數(shù)中的高效并行任務(wù)處理：使用 go 關(guān)鍵字啟動并發(fā)例程。使用 sync.WaitGroup 計(jì)數(shù)未完成例程的數(shù)量。例程完成時調(diào)用 wg.Done() 遞減計(jì)數(shù)器。主程序使用 wg.Wait() 阻塞，直到所有例程完成。實(shí)戰(zhàn)案例：并發(fā)發(fā)送 Web 請求并收集響應(yīng)。

Go 函數(shù)中的高效并行任務(wù)處理

Go 語言提供了強(qiáng)大的并行處理能力，使開發(fā)人員能夠輕松地創(chuàng)建并執(zhí)行并發(fā)任務(wù)。本文將討論如何使用 Go 函數(shù)高效地處理并行任務(wù)，并提供一個實(shí)戰(zhàn)案例來演示它的用法。

Go 函數(shù)中的并發(fā)

Go 函數(shù)提供了兩個關(guān)鍵字來支持并發(fā)執(zhí)行：go 和 sync.WaitGroup。go 關(guān)鍵字用于啟動并發(fā)的 Go 例程，而 sync.WaitGroup 用于等待所有例程完成。

等待組

sync.WaitGroup 是一個計(jì)數(shù)器，用于跟蹤未完成例程的數(shù)量。當(dāng)例程完成時，它會調(diào)用 wg.Done() 來遞減計(jì)數(shù)器。主程序可以使用 wg.Wait() 方法來阻塞，直到所有例程完成。

實(shí)戰(zhàn)案例：并發(fā) Web 請求

考慮一個場景，我們需要并發(fā)發(fā)送多個 Web 請求并收集響應(yīng)。以下是演示如何使用 Go 函數(shù)進(jìn)行高效并發(fā)任務(wù)處理的代碼：

package main

import (
    "fmt"
    "net/http"
    "sync"
)

func main() {
    // 要發(fā)送的 Web 請求 URL
    urls := []string{"https://example.com", "https://example2.com", "https://example3.com"}

    // 創(chuàng)建等待組
    var wg sync.WaitGroup

    for _, url := range urls {
        // 啟動一個并發(fā)例程來發(fā)送 Web 請求
        wg.Add(1)
        go func(url string) {
            // 發(fā)送 GET 請求
            resp, err := http.Get(url)
            if err != nil {
                fmt.Printf("Error getting %s: %v\n", url, err)
            } else {
                fmt.Printf("Status code for %s: %d\n", url, resp.StatusCode)
            }

            // 例程完成，遞減等待組計(jì)數(shù)
            wg.Done()
        }(url)
    }

    // 等待所有例程完成
    wg.Wait()
}

在上面的代碼中：

• 我們使用 sync.WaitGroup 來跟蹤未完成例程的數(shù)量。
• 對于每個 Web 請求 URL，我們啟動一個并發(fā)的 Go 例程來發(fā)送請求。
• 例程使用 wg.Done() 來表示它已完成。
• 主程序使用 wg.Wait() 阻塞，直到所有例程完成。

通過使用這種方法，我們可以并發(fā)發(fā)送多個 Web 請求，并無需等待每個請求的響應(yīng)即可繼續(xù)執(zhí)行主程序。

以上是Golang 函數(shù)如何高效處理并行任務(wù)的詳細(xì)內(nèi)容。更多信息請關(guān)注PHP中文網(wǎng)其他相關(guān)文章！