Toggle Navigation
首页
Golang
PHP
Laravel
Magento
Linux
数据库
MySQL
Redis
Mongodb
热门知识
程序与生活
架构师之路
静态站点
GitHub
主页
Golang中子goroutine与主协程同步的四种实现
Golang中子goroutine与主协程同步的四种实现
06-12
Mark
962
###如何实现子goroutine与主线程的同步### 1、第一种方式:time.sleep(): ```golang package main import ( "fmt" "time" ) func printCount() { for i := 0; i < 10; i++ { fmt.Println(i) } } func main() { go printCount() time.Sleep(time.Millisecond * 100) } ``` 这种方式没法正确预估goroutine执行的时间,很死板,不推荐使用。 2、第二种方式:使用channel机制,每个goroutine传一个channel进去然后往里写数据,在再主线程中读取这些channel,直到全部读到数据了子goroutine也就全部运行完了,那么主goroutine也就可以结束了。这种模式是子线程去通知主线程结束。 ```golang package main import ( "fmt" ) func printCount(rs chan int) { defer close(rs) for i := 0; i < 10; i++ { rs <- i } } func main() { rs := make(chan int, 10) go printCount(rs) for v := range rs { fmt.Println(v) } } ``` 3、第三种方式:使用context中cancel函数,这种模式是主线程去通知子线程结束。 ```golang package main import ( "context" "fmt" ) func printCount(ctx context.Context) chan int { dst := make(chan int) n := 0 go func() { for { select { case <-ctx.Done(): return case dst <- n: n++ } } }() return dst } func main() { ctx, cancel := context.WithCancel(context.Background()) defer cancel() intChan := printCount(ctx) for n := range intChan { if n == 9 { break } fmt.Println(n) } } ``` 4、第四种方式:sync.WaitGroup模式,Add方法设置等待子goroutine的数量,使用Done方法设置等待子goroutine的数量减1,当等待的数量等于0时,Wait函数返回。 ```golang package main import ( "fmt" "sync" ) func printCount(wgp *sync.WaitGroup) { defer wgp.Done() for i := 0; i < 10; i++ { fmt.Println(i) } } func main() { wgp := &sync.WaitGroup{} wgp.Add(1) go printCount(wgp) wgp.Wait() } ```
最新文章
Golang内存问题处理
WebSocket详解
Gopher面试中的Coding(三)
Golang用os/signal包实现平滑重载配置文件
Nginx实现负载均衡的几种方式
Golang中子goroutine与主协程同步的四种实现
Dockerfile文件详解
Golang开发微信公众号
最热文章
Magento实现下载csv数据表格
1887
Laravel带有条件搜索的分页
1808
Magento上传文件、缩略图和导出CSV
1758
Golang开发微信公众号
1728
Magento添加Advanced Dataflow
1715
Magento后台添加rule规则
1639
Magento优化 – MySQL读写分离
1589
Magento常用模块分享
1517
热门标签
下载
laravel分页
上传
导出
微信公众号
Dataflow
rule
规则
读写分离
模块
shell
正则
内存泄漏
Collection
binlog
命名空间
Git
处理
composer
string
package
解锁
锁表
redis sentinel
函数
事务处理
time
架构
系统
读写
golang
事务处理
缓存
日志分析
进阶
schedule
fmt
表分割
Gopher面试
交叉编译
日志分割
事务
分布式锁
HTTPS
Dockerfile
mongodb
channel
git服务器
gogs
php
protobuf
重载配置
版本号
多数据库
负载均衡
concat
mongodb
日志过滤
发展方向
defer
panic
模型关系
goroutine
json
get
post
protobuf
golang算法
代码部署
算法
rpc
docker
elasticsearch
redis
写文件
主从配置
websocket
laravel
package
生成插件
直接下载
数据类型
curl
并发
量级
错误传递
成长
Shell
Go指针
grpc
方法
参数
队列
protobuf
Redis持久化
路上
风景
yum