在 go 編程中，函數(shù)和 goroutine 協(xié)同實(shí)現(xiàn)并發(fā)。goroutine 在函數(shù)中創(chuàng)建，函數(shù)的局部變量在 goroutine 中可見。goroutine 可以在實(shí)戰(zhàn)中用于并發(fā)處理任務(wù)，如并發(fā)文件上傳，通過創(chuàng)建負(fù)責(zé)上傳不同文件的 goroutine 提高效率。使用 goroutine 時(shí)需注意：創(chuàng)建 goroutine 需適量避免資源匱乏；goroutine 無返回值，獲取結(jié)果需使用并發(fā)原語；goroutine 無法直接停止或取消。
Go 函數(shù)與 Goroutine 的協(xié)同
在 Go 編程語言中，goroutine 是一種并發(fā)機(jī)制，可以創(chuàng)建輕量級線程來執(zhí)行代碼。函數(shù)和 goroutine 相互配合，可以實(shí)現(xiàn)高效并發(fā)的編程。
函數(shù)與 Goroutine 的聯(lián)系
Goroutine 可以在函數(shù)內(nèi)部創(chuàng)建，函數(shù)中的局部變量和常量在 goroutine 中可見。Goroutine 結(jié)束時(shí)，其局部變量和常量將被回收。
以下示例展示了如何在函數(shù)中創(chuàng)建 goroutine 并傳遞參數(shù)：
package main
import (
"fmt"
"time"
)
func printHello(name string) {
fmt.Printf("Hello, %s!\n", name)
}
func main() {
go printHello("World")
time.Sleep(1 * time.Second)
}
登錄后復(fù)制
在上述示例中，main 函數(shù)創(chuàng)建一個(gè) goroutine 并傳入?yún)?shù)"World"。goroutine 執(zhí)行 printHello 函數(shù)，打印出 "Hello, World!\n"。
實(shí)戰(zhàn)案例：并發(fā)文件上傳
考慮一個(gè)需要并發(fā)上傳多個(gè)文件的用例：
package main
import (
"context"
"fmt"
"io"
"os"
"path/filepath"
"time"
"cloud.google.com/go/storage"
)
func uploadFile(w io.Writer, bucketName, objectName string) error {
ctx := context.Background()
client, err := storage.NewClient(ctx)
if err != nil {
return fmt.Errorf("storage.NewClient: %v", err)
}
defer client.Close()
f, err := os.Open(objectName)
if err != nil {
return fmt.Errorf("os.Open: %v", err)
}
defer f.Close()
ctx, cancel := context.WithTimeout(ctx, time.Second*30)
defer cancel()
o := client.Bucket(bucketName).Object(objectName)
wc := o.NewWriter(ctx)
if _, err := io.Copy(wc, f); err != nil {
return fmt.Errorf("io.Copy: %v", err)
}
if err := wc.Close(); err != nil {
return fmt.Errorf("Writer.Close: %v", err)
}
fmt.Fprintf(w, "File %v uploaded to %v.\n", objectName, bucketName)
return nil
}
func main() {
bucketName := "bucket-name"
objectNames := []string{"file1.txt", "file2.txt", "file3.txt"}
for _, objectName := range objectNames {
go uploadFile(os.Stdout, bucketName, objectName)
}
}
登錄后復(fù)制
在這個(gè)案例中，main 函數(shù)創(chuàng)建一個(gè) goroutine 列表，每個(gè) goroutine 從操作系統(tǒng)中讀取一個(gè)文件并將其上傳到 Google Cloud Storage。這允許應(yīng)用程序并發(fā)上傳多個(gè)文件，從而顯著提高性能。
注意事項(xiàng)
使用 goroutine 時(shí)需要注意以下事項(xiàng)：
Goroutine 是輕量級的，因此很容易創(chuàng)建大量 goroutine。確保不會(huì)創(chuàng)建過多的 goroutine 而導(dǎo)致程序資源匱乏。
Goroutine 退出時(shí)不帶任何返回值。如果要獲取 goroutine 的結(jié)果，請使用通道或其他并發(fā)性原語。
Goroutine 是匿名的，因此無法直接停止或取消單個(gè) goroutine。
