如何使用Golang函数处理异步操作？-Golang-PHP中文网

如何使用Golang函数处理异步操作？

PHPz

发布： 2024-04-12 22:30:02

原创

597人浏览过

使用函数处理异步操作分为三个步骤：创建协程以并发执行代码块。使用信道在协程之间发送数据，例如结果或错误。使用协程执行异步任务并从信道接收结果。

如何使用Golang函数处理异步操作？

如何使用 Golang 函数处理异步操作？

在 Golang 中，使用函数处理异步操作是一种常见模式。函数可以作为协程运行，允许并发执行代码块而不阻塞主线程。

协程

协程是轻量级线程，可以在不创建新操作系统线程的情况下并发执行代码。协程由 go 关键字创建，后跟要执行的函数：

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

登录后复制

信道

信道是一种通信机制，用于在协程和主线程或不同协程之间发送数据。

立即学习“go语言免费学习笔记（深入）”；

动态WEB网站中的PHP和MySQL：直观的QuickPro指南第2版

动态WEB网站中的PHP和MySQL详细反映实际程序的需求，仔细地探讨外部数据的验证(例如信用卡卡号的格式)、用户登录以及如何使用模板建立网页的标准外观。动态WEB网站中的PHP和MySQL的内容不仅仅是这些。书中还提到如何串联JavaScript与PHP让用户操作时更快、更方便。还有正确处理用户输入错误的方法，让网站看起来更专业。另外还引入大量来自PEAR外挂函数库的强大功能，对常用的、强大的包

508

查看详情

对于异步操作，可以使用信道接收协程执行的结果或错误。

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)
  }
}

登录后复制