Golang 함수를 사용하여 비동기 작업을 처리하는 방법은 무엇입니까?-Golang-php.cn

Golang 함수를 사용하여 비동기 작업을 처리하는 방법은 무엇입니까?

PHPz

풀어 주다： 2024-04-12 22:30:02

원래의

486명이 탐색했습니다.

함수를 사용하여 비동기 작업을 처리하는 것은 세 단계로 나뉩니다. 코드 블록을 동시에 실행하는 코루틴을 만듭니다. 코루틴 간에 결과, 오류 등의 데이터를 전송하려면 채널을 사용하세요. 코루틴을 사용하여 비동기 작업을 수행하고 채널에서 결과를 수신합니다.

Golang 함수를 사용하여 비동기 작업을 처리하는 방법은 무엇입니까?

Golang에서는 함수를 사용하여 비동기 작업을 처리하는 것이 일반적인 패턴입니다. 함수는 코루틴으로 실행될 수 있으므로 메인 스레드를 차단하지 않고도 코드 블록을 동시에 실행할 수 있습니다.

코루틴

코루틴은 새로운 운영 체제 스레드를 만들지 않고도 코드를 동시에 실행할 수 있는 경량 스레드입니다. 코루틴은 go 키워드와 실행할 함수를 사용하여 생성됩니다.

go func() {
  // 异步代码在此处执行
}

로그인 후 복사

Channel

채널은 코루틴과 메인 스레드 또는 다른 코루틴 간에 데이터를 전송하는 데 사용되는 통신 메커니즘입니다.

비동기 작업의 경우 채널을 사용하여 코루틴 실행 결과나 오류를 수신할 수 있습니다.

result := make(chan int)

go func() {
  // 异步代码在此处执行
  result <- resultValue
}

로그인 후 복사

실용 사례: 웹 페이지 동시 크롤링

일련의 URL을 동시에 크롤링하는 실제 사례를 고려해 보겠습니다.

package main

import (
  "fmt"
  "io/ioutil"
  "net/http"
)

func main() {
  urls := []string{"url1", "url2", "url3"}
  results := make(chan string)

  // 为每个 URL 创建一个协程
  for _, url := range urls {
    go func(url string) {
      // 爬取网页并发送结果到信道
      resp, err := http.Get(url)
      if err != nil {
        results <- fmt.Sprintf("Error getting %s: %v", url, err)
        return
      }
      defer resp.Body.Close()
      body, err := ioutil.ReadAll(resp.Body)
      if err != nil {
        results <- fmt.Sprintf("Error reading body of %s: %v", url, err)
        return
      }
      results <- fmt.Sprintf("Got body of %s: %s", url, string(body))
    }(url)
  }

  // 从信道接收结果并打印
  for i := 0; i < len(urls); i++ {
    fmt.Println(<-results)
  }
}

로그인 후 복사