Toggle Navigation
首页
Golang
PHP
Laravel
Magento
Linux
数据库
MySQL
Redis
Mongodb
热门知识
程序与生活
架构师之路
静态站点
GitHub
主页
Golang中子goroutine与主协程同步的四种实现
Golang中子goroutine与主协程同步的四种实现
06-12
Mark
892
###如何实现子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数据表格
1797
Laravel带有条件搜索的分页
1692
Magento上传文件、缩略图和导出CSV
1690
Magento添加Advanced Dataflow
1641
Golang开发微信公众号
1570
Magento后台添加rule规则
1543
Magento优化 – MySQL读写分离
1509
Magento常用模块分享
1401
热门标签
下载
laravel分页
上传
导出
Dataflow
微信公众号
rule
规则
读写分离
模块
shell
正则
Collection
binlog
命名空间
处理
内存泄漏
Git
string
composer
解锁
锁表
事务处理
函数
redis sentinel
架构
系统
time
package
读写
事务处理
日志分析
进阶
缓存
golang
表分割
schedule
fmt
事务
分布式锁
交叉编译
HTTPS
日志分割
Gopher面试
mongodb
Dockerfile
channel
多数据库
git服务器
gogs
重载配置
负载均衡
日志过滤
php
protobuf
发展方向
版本号
模型关系
goroutine
concat
json
mongodb
get
post
defer
panic
golang算法
算法
docker
elasticsearch
rpc
代码部署
redis
主从配置
写文件
protobuf
laravel
websocket
并发
量级
package
curl
生成插件
直接下载
数据类型
Shell
错误传递
成长
grpc
参数
Go指针
队列
protobuf
方法
Redis持久化
路上
风景
yum