在 go 编程中，函数和 goroutine 协同实现并发。goroutine 在函数中创建，函数的局部变量在 goroutine 中可见。goroutine 可以在实战中用于并发处理任务，如并发文件上传，通过创建负责上传不同文件的 goroutine 提高效率。使用 goroutine 时需注意：创建 goroutine 需适量避免资源匮乏；goroutine 无返回值，获取结果需使用并发原语；goroutine 无法直接停止或取消。
Go 函数与 Goroutine 的协同
在 Go 编程语言中，goroutine 是一种并发机制，可以创建轻量级线程来执行代码。函数和 goroutine 相互配合，可以实现高效并发的编程。
函数与 Goroutine 的联系
Goroutine 可以在函数内部创建，函数中的局部变量和常量在 goroutine 中可见。Goroutine 结束时，其局部变量和常量将被回收。
以下示例展示了如何在函数中创建 goroutine 并传递参数：
立即学习“go语言免费学习笔记（深入）”；
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 时需要注意以下事项：
- Goroutine 是轻量级的，因此很容易创建大量 goroutine。确保不会创建过多的 goroutine 而导致程序资源匮乏。
- Goroutine 退出时不带任何返回值。如果要获取 goroutine 的结果，请使用通道或其他并发性原语。
- Goroutine 是匿名的，因此无法直接停止或取消单个 goroutine。
