Golang 프레임워크와 Elixir 프레임워크: 동시 프로그래밍에 대한 독특한 관점-Golang-php.cn

Golang 프레임워크와 Elixir 프레임워크: 동시 프로그래밍에 대한 독특한 관점

PHPz

풀어 주다： 2024-06-06 13:04:57

원래의

501명이 탐색했습니다.

Golang의 Goroutine과 Elixir의 Erlang VM은 고유한 동시 프로그래밍 모델을 제공합니다. Golang은 경량 병렬 스레드(goroutines)를 사용하여 단일 프로세스에서 작업을 효율적으로 예약하고, Elixir는 Erlang 가상 머신(BEAM)을 기반으로 프로세스 메커니즘을 통해 동시성을 표현합니다. 실제 사례에서는 효율성을 높이기 위해 Goroutine 또는 Erlang VM을 사용하여 크롤링 작업을 병렬로 실행할 수 있습니다.

Golang 프레임워크와 Elixir 프레임워크: 동시 프로그래밍에 대한 독특한 관점

Golang Framework 및 Elixir Framework: 동시 프로그래밍에 대한 독특한 관점

현대 소프트웨어 개발에서 동시 프로그래밍은 필수 기술이 되었습니다. Golang과 Elixir는 독특한 동시 프로그래밍 모델을 제공하는 두 가지 인기 있는 프로그래밍 언어입니다. 이 튜토리얼에서는 이러한 모델을 살펴보고 실제 예제를 통해 시연해 보겠습니다.

Golang의 Goroutine

Golang은 호출하는 함수를 차단하지 않고 작업을 동시에 실행할 수 있는 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는 동시성과 내결함성이 뛰어난 런타임 환경인 BEAM(Erlang Virtual Machine)을 기반으로 합니다. 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))
}

로그인 후 복사