Golang フレームワークと Elixir フレームワーク: 同時プログラミングに関する独自の視点-Golang-php.cn

Golang フレームワークと Elixir フレームワーク: 同時プログラミングに関する独自の視点

PHPz

リリース： 2024-06-06 13:04:57

オリジナル

470 人が閲覧しました

Golang の Goroutine と Elixir の Erlang VM は、独自の同時プログラミングモデルを提供します。 Golang は軽量の並列スレッド (ゴルーチン) を使用して単一プロセスでタスクを効率的にスケジュールし、Elixir は Erlang 仮想マシン (BEAM) に基づいてプロセスメカニズムを通じて同時実行性を表現します。実際のケースでは、Goroutine または Erlang VM を使用してクロールタスクを並行して実行し、効率を向上させることができます。

Golang フレームワークと Elixir フレームワーク: 同時プログラミングに関する独自の視点

現代のソフトウェア開発では、同時プログラミングは不可欠なテクノロジーになっています。 Golang と Elixir は、独自の同時プログラミングモデルを提供する 2 つの人気のあるプログラミング言語です。このチュートリアルでは、これらのモデルを調べ、実践的な例を示します。

Golang の Goroutine

Golang は、それを呼び出す関数をブロックすることなくタスクを同時実行できる goroutine と呼ばれる軽量の並列スレッドを提供します。 Goroutine は、コルーチンメカニズムを使用して、単一プロセスでの複数の同時操作を効率的にスケジュールします。

package main

import (
    "fmt"
    "runtime"
    "time"
)

func main() {
    // 创建一个 goroutine
    go func() {
        for i := 0; i < 10; i++ {
            fmt.Println("goroutine:", i)
        }
    }()

    // 主线程继续执行
    for i := 0; i < 10; i++ {
        fmt.Println("main:", i)
    }

    // 确保 goroutine 完成后再退出
    time.Sleep(1 * time.Second)

    // 输出
    // goroutine: 0
    // main: 0
    // goroutine: 1
    // main: 1
    // ...
    // goroutine: 9
    // main: 9
}

ログイン後にコピー

Elixir の Erlang VM

Elixir は、高度な同時実行性と耐障害性を備えたランタイム環境である Erlang Virtual Machine (BEAM) に基づいています。 BEAM は Erlang、Elixir、およびその他の BEAM ベースの言語を実装し、同時実行性を表現するプロセスと呼ばれるメカニズムを提供します。

defmodule MyModule do
  def main do
    # 创建一个进程并向其发送消息
    spawn(fn ->
      receive do
        {_, msg} ->
          IO.println("进程收到消息: #{msg}")
      end
    end)

    # 主进程继续执行
    for i <- 1..10 do
      send(self(), {self(), "消息 #{i}"})
    end
  end
end

MyModule.main

ログイン後にコピー

実際のケース: 並列クロール

Golang の Goroutine または Elixir の Erlang VM を使用すると、クロールタスクを並列で実行できます。以下は Golang を使用して実装された例です:

package main

import (
    "fmt"
    "io/ioutil"
    "net/http"
    "runtime"
    "sync"
    "time"
)

func main() {
    // 创建一个同步锁来维护结果
    var lock sync.Mutex
    var wg sync.WaitGroup

    // 创建一个通道来存储结果
    results := make(chan string)

    // 爬取 URL 列表
    urls := []string{"www.google.com", "www.amazon.com", "www.facebook.com"}
    startTime := time.Now()

    for _, url := range urls {
        // 创建一个 goroutine 来爬取每个 URL
        wg.Add(1)

        go func(url string) {
            defer wg.Done()

            // 发送 HTTP 请求
            resp, err := http.Get(url)
            if err != nil {
                results <- fmt.Sprintf("爬取失败: %s", err)
                return
            }

            // 读取并打印响应内容
            contents, err := ioutil.ReadAll(resp.Body)
            resp.Body.Close()
            if err != nil {
                results <- fmt.Sprintf("读取内容失败: %s", err)
                return
            }

            // 使用锁来安全地存储结果
            lock.Lock()
            defer lock.Unlock()
            results <- fmt.Sprintf("爬取成功: %s\n内容:\n%s", url, contents)
        }(url)
    }

    // 等待所有 goroutine 完成
    wg.Wait()
    close(results)

    // 打印结果
    for result := range results {
        fmt.Println(result)
    }

    fmt.Printf("爬取完成，用时：%v\n", time.Since(startTime))
}

ログイン後にコピー