goroutine只是由官方实现的超级"线程池"而已,每个实例4-5kb的栈内存占用和用于实现机制而大幅减少的创建和销毁开销。
并发不是并行(多CPU): Concurrency Is Not Parallelism
并发主要由切换时间片来实现"同时"运行,并行则是直接利用多核实现多线程的运行,但Go可以设置使用核数,以发挥多核计算机的能力。
package main
import (
"fmt"
"time"
)
func Go() {
fmt.Println("1234...")
}
func main() {
go Go() //go关键字构成多线程
time.Sleep(2 * time.Second) //主程序睡眠2s
}
Goroutine 奉行通过 通信来共享内存 ,而不是 共享内存来通信 。
Channel
package main
import (
"fmt"
)
func main() { //主程序
c := make(chan bool) //初始化一个chan类型
go func() { //子程序
fmt.Println("123...") //执行主程序
c <- true //通过<-存入bool类型到chan中
}()
fmt.Println(1) //程序执行步骤:1st
read_chan := <-c //<-c 从chan中读取bool,程序执行步骤:2nd
fmt.Println(read_chan) //程序执行步骤:3rd
}
/*output
1st 1
2nd 123...
3rd true
*/
注意以上程序的执行顺序(channel无缓存时):先执行读取操作 c<-c ,因为channel中没有值,所以程序发生阻塞,此时执行chanel 写操作 ,然后再执行读操作。
package main
import (
"fmt"
)
func main() {
c := make(chan bool) //初始化一个chan类型
go func() { //go结合匿名函数,构造并发
fmt.Println("123...") //执行主程序
c <- true //通过<-存入bool类型到chan中
close(c) //关闭通道:必须明确在哪个地方关闭
}()
for v := range c { //for循环chanel
}
}
/*output
123...
true
*/
package main
import (
"fmt"
)
func main() { //主程序
c := make(chan bool, 1) //初始化一个chan类型,缓存为2
go func() { //子程序
fmt.Println("123...") //执行主程序,执行步骤:2
c <- true //写操作,执行步骤:2
}()
fmt.Println(2) //执行步骤:1
fmt.Println(123, <-c) //读操作,执行步骤:2
fmt.Println(3) //执行步骤:3
}
/*output
1 2
2 123...
2 123 true
3 3
*/
设置缓存后,程序为异步,读,写操作同时完成,当读取channal中无数据时,也不会造成堵塞,因为与此同时,写操作也将发生。
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持亿速云。
亿速云「云服务器」,即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘,价格低至29元/月。点击查看>>
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。