分散システムにおける Golang 関数の並列プログラミング-Golang-php.cn

分散システムにおける Golang 関数の並列プログラミング

WBOY

リリース： 2024-04-19 11:51:02

オリジナル

515 人が閲覧しました

分散システムでは、Go 関数は Goroutine と Channel を通じて並列プログラミングを実装し、システムのパフォーマンスを大幅に向上させます。 Goroutine は go キーワードによって開始される軽量のスレッドであり、異なる CPU コアで同時に実行できます。 Channel は goroutine 間の通信のためのパイプラインであり、make 関数を使用して作成されます。実際のケースでは、同時クローラーの例で、Goroutine と Channel を使用して並列クロールを行う方法を示します。並列プログラミングには、パフォーマンスの向上、スケーラビリティ、リソース使用量の削減などの利点がありますが、同期の問題、競合状態、デッドロックなどの注意点もあります。

Golang 函数在分布式系统中的并行编程

#分散システムにおける Go 関数の並列プログラミング

分散システムでは、並列プログラミングによりシステムのパフォーマンスが大幅に向上します。 Go 言語に組み込まれた同時実行機能により、開発者は並列コードを簡単に作成できます。この記事では、並列プログラミングに Go 関数を使用する方法を検討し、参考として実際のケースを提供します。

Goroutine

Goroutine は Go 言語の軽量スレッドです。別個のプロセスを作成することなく、異なる CPU コアで同時に実行できます。 Goroutine は、次のように

go キーワードによって開始されます。

package main

func main() {
    go func() {
        // 并行执行的任务
    }()
}

ログイン後にコピー

Channel

Channel は、パイプラインの Goroutine 間の通信に Go 言語で使用されます。これにより、Goroutine は異なるスレッド間でデータを安全に受け渡すことができ、並列処理が可能になります。以下に示すように、チャネルは

make 関数を使用して作成されます。

ch := make(chan int)

ログイン後にコピー

実践的なケース: 同時実行クローラー

並列プログラミングをより深く理解するためにGo 関数の例として、同時実行クローラーの簡単な例を作成します。

package main

import (
    "fmt"
    "net/http"
)

func main() {
    urls := []string{
        "https://example.com",
        "https://example2.com",
        "https://example3.com",
    }

    ch := make(chan string)

    // 创建 Goroutine 进行并行爬取
    for _, url := range urls {
        go crawl(url, ch)
    }

    // 从 Channel 中接收爬取结果
    for i := 0; i < len(urls); i++ {
        fmt.Println(<-ch)
    }
}

func crawl(url string, ch chan string) {
    resp, err := http.Get(url)
    if err != nil {
        return
    }
    defer resp.Body.Close()

    ch <- resp.Status
}

ログイン後にコピー

利点

Go 関数を並列プログラミングに使用すると、次のような利点があります: