go 語言中使用 goroutine 實現異步編程。 goroutine 是一種輕量級線程，可以通過 go 關鍵字異步執行函數。 例如，在并發處理文件時，多個 goroutine 可以并行處理文件，提高處理速度。
Go 函數中的異步編程：使用 Goroutine
在 Go 語言中，并發編程通過 Goroutine 實現，Goroutine 是一種輕量級線程，可以并行執行。Goroutine 與傳統線程的主要區別在于，它非常輕量，創建和銷毀的成本都很低。此外，Goroutine 也是由 Go 語言的運行時調度，無需手動管理，這使得并發編程更加簡單高效。
通過 Goroutine 實現異步編程
使用 Goroutine 異步處理函數非常簡單。只需創建一個 Goroutine，并將要異步執行的函數作為參數傳遞給 go 關鍵字即可。例如，以下代碼段展示了如何使用 Goroutine 異步執行一個簡單的打印任務：
package main
import (
"fmt"
"time"
)
func main() {
// 創建一個 Goroutine 并異步執行 printTask 函數
go printTask()
// 繼續執行主 Goroutine
fmt.Println("Main Goroutine")
time.Sleep(1 * time.Second)
}
func printTask() {
fmt.Println("Asynchronous Task")
}
登錄后復制
運行這段代碼，你會看到主 Goroutine 立即打印 “Main Goroutine”，而異步任務稍后打印 “Asynchronous Task”，這表明異步任務在 Goroutine 中運行。
實戰案例：并行處理文件
使用 Goroutine 實現異步編程的一個實戰案例是并行處理文件。假設我們有一個包含大量文件的文件夾，需要對每個文件進行一些處理。我們可以使用 Goroutine 并行處理這些文件，從而顯著提高處理速度。
以下代碼段展示了如何使用 Goroutine 并行處理文件：
package main
import (
"fmt"
"io/ioutil"
"os"
"strconv"
"sync"
"time"
)
func main() {
// 獲取需要處理的文件列表
files, err := ioutil.ReadDir("./files")
if err != nil {
fmt.Println(err)
return
}
// 創建一個等待組來等待所有 Goroutine 完成
var wg sync.WaitGroup
wg.Add(len(files))
// 并行處理每個文件
for i, file := range files {
go processFile(file.Name(), i, &wg)
}
// 等待所有 Goroutine 完成
wg.Wait()
fmt.Println("All files processed")
}
func processFile(filename string, index int, wg *sync.WaitGroup) {
defer wg.Done()
// 讀取文件內容
content, err := ioutil.ReadFile("./files/" + filename)
if err != nil {
fmt.Println(err)
return
}
// 對文件內容進行一些處理
processedContent := strconv.Itoa(index) + ": " + string(content)
// 將處理后的內容寫入一個新文件
if err := ioutil.WriteFile("./processed_files/"+filename, []byte(processedContent), 0644); err != nil {
fmt.Println(err)
return
}
// 打印處理完成的消息
fmt.Printf("File %s processed\n", filename)
}
登錄后復制
運行這段代碼，你會看到多個 Goroutine 并行處理文件，從而顯著提高處理速度。
