协程等待:通过 channel 或 context 实现
想要等待多个子协程执行完毕,可以通过使用 channel 或 context 实现,类似于 sync.waitgroup 的功能。
channel
channel 用于在协程间通讯。可以通过创建一个缓冲 channel,并为每个协程发送一个值,来实现子协程完成后通知主协程。
import "math/rand" import "time" func main() { const num = 10 ch := make(chan int, num) for i := 0; i < num; i++ { go func() { fmt.println("goroutine start: ", i) t := rand.intn(5) + 1 time.sleep(time.duration(t) * time.second) fmt.println("goroutine end: ", i) ch <- 0 }() } fmt.println("main start") for i := 0; i < num; i++ { <-ch fmt.println("main get: ", i) } fmt.println("main end") }
context
context 是一种更通用的机制,可以用来传播取消信号或其他值。可以通过使用 withcancel 函数创建一个 context,并传递给子协程。当主协程取消 context 时,子协程会自动终止。
import "context" func main() { const num = 10 ctx, cancel := context.WithCancel(context.Background()) ch := make(chan int, num) for i := 0; i < num; i++ { go func(ctx context.Context) { fmt.Println("goroutine start: ", i) select { case <-ctx.Done(): fmt.Println("goroutine cancelled: ", i) return default: } t := rand.Intn(5) + 1 time.Sleep(time.Duration(t) * time.Second) fmt.Println("goroutine end: ", i) ch <- 0 }(ctx) } fmt.Println("main start") for i := 0; i < num; i++ { <-ch fmt.Println("main get: ", i) } cancel() fmt.Println("main end") }
以上就是如何使用 Channel 或 Context 等待多个子协程执行完毕?的详细内容,更多请关注php中文网其它相关文章!
每个人都需要一台速度更快、更稳定的 PC。随着时间的推移,垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是,许多工具可以让 Windows 保持平稳运行。
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号