在 Go 程式設計中,函數和 goroutine 協同實作並發。 goroutine 在函數中創建,函數的局部變數在 goroutine 中可見。 goroutine 可以在實戰中用於並發處理任務,例如並發檔案上傳,透過建立負責上傳不同檔案的 goroutine 來提高效率。使用 goroutine 時需注意:創建 goroutine 需適量避免資源匱乏;goroutine 無回值,取得結果需使用並發原語;goroutine 無法直接停止或取消。
#在 Go 程式語言中,goroutine 是一種並發機制,可以建立輕量級執行緒來執行程式碼。函數和 goroutine 相互配合,可以實現高效並發的程式設計。
Goroutine 可以在函數內部創建,函數中的局部變數和常數在 goroutine 中可見。 Goroutine 結束時,其局部變數和常數將被回收。
以下範例展示如何在函數中建立goroutine 並傳遞參數:
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) }
在上述範例中,main
函數建立一個goroutine 並傳入參數 "World"
。 goroutine 執行 printHello
函數,印出 "Hello, World!\n"
。
考慮一個需要並發上傳多個檔案的用例:
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) } }
在這個案例中,main
函數創建一個goroutine 列表,每個goroutine 從作業系統中讀取一個檔案並將其上傳到Google Cloud Storage。這允許應用程式並發上傳多個文件,從而顯著提高效能。
使用 goroutine 時需要注意以下事項:
以上是golang函數與goroutine的協同的詳細內容。更多資訊請關注PHP中文網其他相關文章!