在 go 编程中,函数和 goroutine 协同实现并发。goroutine 在函数中创建,函数的局部变量在 goroutine 中可见。goroutine 可以在实战中用于并发处理任务,如并发文件上传,通过创建负责上传不同文件的 goroutine 提高效率。使用 goroutine 时需注意:创建 goroutine 需适量避免资源匮乏;goroutine 无返回值,获取结果需使用并发原语;goroutine 无法直接停止或取消。

Go 函数与 Goroutine 的协同
在 Go 编程语言中,goroutine 是一种并发机制,可以创建轻量级线程来执行代码。函数和 goroutine 相互配合,可以实现高效并发的编程。
函数与 Goroutine 的联系
Goroutine 可以在函数内部创建,函数中的局部变量和常量在 goroutine 中可见。Goroutine 结束时,其局部变量和常量将被回收。
以下示例展示了如何在函数中创建 goroutine 并传递参数:
立即学习“go语言免费学习笔记(深入)”;
eSiteGroup站群管理系统是基于eFramework低代码开发平台构建,是一款高度灵活、可扩展的智能化站群管理解决方案,全面支持SQL Server、SQLite、MySQL、Oracle等主流数据库,适配企业级高并发、轻量级本地化、云端分布式等多种部署场景。通过可视化建模与模块化设计,系统可实现多站点的快速搭建、跨平台协同管理及数据智能分析,满足政府、企业、教育机构等组织对多站点统一管控的
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。









