golang函數的異步編程實踐

2024-04-29 16:04:18 綜合教程 52

異步編程允許在不阻塞主線程的情況下執行任務。go 語言使用輕量級線程 goroutine 和通信管道 channel 實現異步編程。goroutine 通過 go 關鍵字創建，而 channel 用于在 goroutine 之間發送和接收數據。實戰案例：并發 web 請求使用一個 channel 來接收請求響應，并通過 goroutine 并發發送 http get 請求。主線程從 channel 中接收響應并打印結果，提高了程序性能和響應能力。

Go 語言函數的異步編程實踐

異步編程是并行編程的一種技術，它允許程序員在不阻塞主線程的情況下執行多個任務。在 Go 語言中，使用和可以輕松地實現異步編程。

Goroutine

Goroutine 是 Go 語言中的輕量級線程。與傳統線程不同，goroutine 非常輕量，并且由 Go 運行時管理。使用關鍵字可以創建 goroutine。

go func() {
  // 異步任務
}

channel

channel 是 Go 語言用來在 goroutine 之間通信的管道。channel 可以被用于發送和接收數據。

ch := make(chan int)  // 創建一個無緩沖 channel

// 向 channel 發送數據
ch <- 42

// 從 channel 接收數據
x := <-ch

實戰案例：并發 web 請求

以下是一個異步并發 web 請求的實戰案例：

package main

import (
  "fmt"
  "net/http"
  "time"
)

func main() {
  // 創建一個 channel 來接收請求響應
  results := make(chan string)

  // 發送<a style='color:#f60; text-decoration:underline;' href="/zt/46006.html" target="_blank">并發請求</a>
  for i := 0; i < 10; i++ {
    go func(i int) {
      // 發送 HTTP GET 請求
      resp, err := http.Get(fmt.Sprintf("example/%d", i))
      if err != nil {
        results <- fmt.Sprintf("Error: %v", err)
        return
      }

      // 接收響應并發送結果
      body, err := ioutil.ReadAll(resp.Body)
      if err != nil {
        results <- fmt.Sprintf("Error: %v", err)
        return
      }

      results <- fmt.Sprintf("Response: %s", string(body))
    }(i)
  }

  // 接收并發請求的響應
  for j := 0; j < 10; j++ {
    fmt.Println(<-results)
  }
}

這個程序創建了一個 channel 來接收請求響應，然后啟動 10 個 goroutine 并發發送 HTTP GET 請求。每個 goroutine 在收到響應后將結果發送到 channel。主線程從 channel 中接收結果并打印到控制臺。

通過異步編程，這個程序可以在不阻塞主線程的情況下并發處理請求，從而提高了應用程序的性能和響應能力。