Golang通过go关键字启动goroutine实现并发,配合channel进行通信,使用WaitGroup等待执行完成,避免竞态与泄漏。

在Golang中实现goroutine并发执行非常直接,Go语言通过轻量级线程(goroutine)和通道(channel)提供了强大的并发支持。你只需要在函数调用前加上 go 关键字,就能启动一个新goroutine并发运行。
启动基本的goroutine
每个goroutine是一个独立执行的函数,由Go运行时调度管理。它比操作系统线程更轻量,可以轻松创建成千上万个。
示例:package mainimport ( "fmt" "time" )
func sayHello() { fmt.Println("Hello from goroutine") }
func main() { go sayHello() // 启动一个goroutine time.Sleep(100 * time.Millisecond) // 等待goroutine执行完成 fmt.Println("Main function ends") }
如果不加 time.Sleep,主程序可能在goroutine执行前就退出了,导致看不到输出。
使用channel进行goroutine通信
多个goroutine之间不能直接共享内存通信,推荐使用channel传递数据,避免竞态条件。
立即学习“go语言免费学习笔记(深入)”;
dmSOBC SHOP网店系统由北京时代胜腾信息技术有限公司(http://www.webzhan.com)历时6个月开发完成,本着简单实用的理念,商城在功能上摒弃了外在装饰的一些辅助功能,尽可能的精简各项模块开发,做到有用的才开发,网店V1.0.0版本开发完成后得到了很多用户的使用并获得了好评,公司立即对网店进行升级,其中包括修正客户提出的一些意见和建议,现对广大用户提供免费试用版本,如您在使用
package mainimport "fmt"
func worker(id int, jobs <-chan int, results chan<- int) { for job := range jobs { fmt.Printf("Worker %d processing job %d\n", id, job) results <- job * 2 } }
func main() { jobs := make(chan int, 5) results := make(chan int, 5)
// 启动3个worker goroutine for w := 1; w <= 3; w++ { go worker(w, jobs, results) } // 发送5个任务 for j := 1; j <= 5; j++ { jobs <- j } close(jobs) // 收集结果 for a := 1; a <= 5; a++ { <-results }}
使用sync.WaitGroup等待所有goroutine完成
当不需要返回值时,可以用 sync.WaitGroup 来等待一组goroutine执行完毕。
示例:package mainimport ( "fmt" "sync" )
func task(id int, wg *sync.WaitGroup) { defer wg.Done() fmt.Printf("Task %d is done\n", id) }
func main() { var wg sync.WaitGroup
for i := 1; i <= 5; i++ { wg.Add(1) go task(i, &wg) } wg.Wait() // 阻塞直到所有task调用Done() fmt.Println("All tasks completed")}
基本上就这些。合理使用go关键字、channel和WaitGroup,就能高效安全地实现并发。注意避免常见问题如goroutine泄漏、死锁和竞态条件。配合context包还能实现超时控制和取消机制。不复杂但容易忽略细节。









