[TOC]
# Gosched
runtime.Gosched()让出cpu的时间片,让出当前协程的执行权限,调度器安排其他等待的任务运行,并在下次某个时间从该位置恢复执行
和协程 yield 作用类似
~~~
func main() {
go func() {
for i := 0; i < 5; i++ {
//不一定打印5次
fmt.Println("go")
}
}() //别忘记()
for i := 0; i < 2; i++ {
//让出我的时间片
runtime.Gosched()
fmt.Println("hello")
}
}
~~~
# Goexit
调用runtime.Goexit()将立即终止当前协程运行,调度器确保所有已注册defer延迟调用执行
有时候我们会遇到这个问题
**调度器确保所有已注册defer延迟调用被执行,要在Goexit之前注册**
~~~
func test() {
defer fmt.Println("test-------")
return //终止使用此函数
fmt.Println("1111111111")
}
func main() {
go func() {
fmt.Println("aaaa")
//调用了别的函数
test()
//没打印
fmt.Println("bbb")
}() //别忘记()
for {
}
}
~~~
输出
~~~
aaaa
test-------
bbb
~~~
~~~
func test() {
defer fmt.Println("test-------")
//终止这个协程
runtime.Goexit()
//return
fmt.Println("1111111111")
}
func main() {
go func() {
fmt.Println("aaaa")
//调用了别的函数
test()
//没打印
fmt.Println("bbb")
}() //别忘记()
for {
}
}
~~~
输出
~~~
aaaa
test-------
~~~
# GOMAXPROCS
调用runtime.GOMAXPROCS()用来设置可以并行计算的cpu核数的最大值,并返回之前的值
~~~
func main() {
//指定核数
n := runtime.GOMAXPROCS(2)
fmt.Println(n)
}
~~~
# 多任务资源竞争
~~~
//定义一个打印机
//打印机属于公共资源
func Printer(str string) {
for _, data := range str{
fmt.Printf("%c", data)
time.Sleep(time.Second)
}
fmt.Printf("\n")
}
func Person1() {
Printer("hello")
}
func Person2() {
Printer("world")
}
func main() {
//新建2个协程,代表2个人,2个人同时使用打印机
go Person1()
go Person2()
//特意不让主协程结束,死循环
for {
}
}
~~~
打印会乱掉
我们如何让他同步呢
# 其他的小功能
返回go的根目录,存在GOROOT环境变量返回该环境变量,不存在返回go的根目录
~~~
func GOROOT() string
~~~
版本
~~~
func Version() string
~~~
cpu个数
~~~
func NumCPU() int
~~~
GC
~~~
func GC()
~~~
# 查看时间
~~~
go build main.go
time -p ./main
~~~
输出结果:
~~~
0 9223372030412324865
1 9223372030412324865
real 1.92 // 程序开始到结束时间差 ( CPU 时间)
user 3.80 // 用户态所使用 CPU 时间片 (多核累加)
sys 0.01 // 内核态所使用 CPU 时间片
~~~
命令行输入:
~~~
GOMAXPROCS=8 time -p ./main
~~~
输出结果:
~~~
1 9223372030412324865
0 9223372030412324865
real 1.89
user 3.76 // 虽然总时间差不多,但由 2 个核并行,real 时间自然少了许多。
sys 0.00
~~~
- 基础
- 简介
- 主要特征
- 变量和常量
- 编码转换
- 数组
- byte与rune
- big
- sort接口
- 和mysql类型对应
- 函数
- 闭包
- 工作区
- 复合类型
- 指针
- 切片
- map
- 结构体
- sync.Map
- 随机数
- 面向对象
- 匿名组合
- 方法
- 接口
- 权限
- 类型查询
- 异常处理
- error
- panic
- recover
- 自定义错误
- 字符串处理
- 正则表达式
- json
- 文件操作
- os
- 文件读写
- 目录
- bufio
- ioutil
- gob
- 栈帧的内存布局
- shell
- 时间处理
- time详情
- time使用
- new和make的区别
- container
- list
- heap
- ring
- 测试
- 单元测试
- Mock依赖
- delve
- 命令
- TestMain
- path和filepath包
- log日志
- 反射
- 详解
- plugin包
- 信号
- goto
- 协程
- 简介
- 创建
- 协程退出
- runtime
- channel
- select
- 死锁
- 互斥锁
- 读写锁
- 条件变量
- 嵌套
- 计算单个协程占用内存
- 执行规则
- 原子操作
- WaitGroup
- 定时器
- 对象池
- sync.once
- 网络编程
- 分层模型
- socket
- tcp
- udp
- 服务端
- 客户端
- 并发服务器
- Http
- 简介
- http服务器
- http客户端
- 爬虫
- 平滑重启
- context
- httptest
- 优雅中止
- web服务平滑重启
- beego
- 安装
- 路由器
- orm
- 单表增删改查
- 多级表
- orm使用
- 高级查询
- 关系查询
- SQL查询
- 元数据二次定义
- 控制器
- 参数解析
- 过滤器
- 数据输出
- 表单数据验证
- 错误处理
- 日志
- 模块
- cache
- task
- 调试模块
- config
- 部署
- 一些包
- gjson
- goredis
- collection
- sjson
- redigo
- aliyunoss
- 密码
- 对称加密
- 非对称加密
- 单向散列函数
- 消息认证
- 数字签名
- mysql优化
- 常见错误
- go run的错误
- 新手常见错误
- 中级错误
- 高级错误
- 常用工具
- 协程-泄露
- go env
- gometalinter代码检查
- go build
- go clean
- go test
- 包管理器
- go mod
- gopm
- go fmt
- pprof
- 提高编译
- go get
- 代理
- 其他的知识
- go内存对齐
- 细节总结
- nginx路由匹配
- 一些博客
- redis为什么快
- cpu高速缓存
- 常用命令
- Go 永久阻塞的方法
- 常用技巧
- 密码加密解密
- for 循环迭代变量
- 备注
- 垃圾回收
- 协程和纤程
- tar-gz
- 红包算法
- 解决golang.org/x 下载失败
- 逃逸分析
- docker
- 镜像
- 容器
- 数据卷
- 网络管理
- 网络模式
- dockerfile
- docker-composer
- 微服务
- protoBuf
- GRPC
- tls
- consul
- micro
- crontab
- shell调用
- gorhill/cronexpr
- raft
- go操作etcd
- mongodb