Golang框架與Elixir框架：並發程式設計的獨特視角-Golang-PHP中文網

Golang框架與Elixir框架：並發程式設計的獨特視角

PHPz

發布： 2024-06-06 13:04:57

原創

484 人瀏覽過

Golang 的 Goroutine 和 Elixir 的 Erlang VM 提供了獨特的並發程式設計模型。 Golang 使用輕量級並行線程 (goroutine) 在單一進程中高效調度任務，Elixir 基於 Erlang 虛擬機器 (BEAM)，透過進程機製表示並發性。實戰案例中，使用 Goroutine 或 Erlang VM 可並行執行爬取任務，提高效率。

Golang框架與Elixir框架：並發程式設計的獨特視角

在現代軟體開發中，並發程式設計已成為必不可少的技術。 Golang 和 Elixir 是兩大流行的程式語言，它們提供了獨特的並發程式設計模型，在本教程中，我們將探討這些模型並透過實戰案例進行演示。

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 虛擬機器 (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))
}

登入後複製