并发concurrency
-很多人都是冲着Go 大肆宣扬的高并发而忍不住跃跃欲试,但其实从源码的解析来看,goroutine只是由官方实现的超级"线程池"而已。不过话说回来,每个实例4-5KB的栈内存占用和由于实现机制而大幅减少的创建和销毁开销,是制造Go号称的高并发的根本原因。另外,goroutine的简单易用,也在语言层面上给予了开发者巨大的便利。
并发不是并行:Concurrency Is Not Parallelism
-并发主要由切换时间片来实现"同时"运行,在并行则是直接利用多核实现多线程的运行,但Go可以设置使用核数,以发挥多核计算机的能力。
Goroutine奉行通过通信来共享内存,而不是共享内存来通信。
Channel
-Channel 是 goroutine沟通的桥梁,大都是阻塞同步的
-通过make创建,close关闭
-Channel是引用类型
-可以使用for range来迭代不断操作Channel
-可以设置单向或双向通道
-可以设置缓存大小,在未补填满前不会发生阻塞
(有缓存异步,无缓存同步)
Select
-可以处理一个或多个channel的发送与接收
-同时有多个可用的 channel时按随机顺序处理
-可用空的select来阻塞main函数
-可设置超时
<code>
package main
import (
"fmt"
)
func main() {
c := make(chan bool)
go func() {
fmt.Println("Go Go Go!!!")
c <- true
}()
<-c
}
</code>
并行示例1
<code>
package main
import (
"fmt"
"runtime"
)
func main() {
runtime.GOMAXPROCS(runtime.NumCPU())
c := make(chan bool, 10)
for i := 0; i < 10; i++ {
go Go(c, i)
}
for i := 0; i < 10; i++ {
<-c
}
}
func Go(c chan bool, index int) {
a := 1
for i := 0; i < 1000000000; i++ {
a += i
}
fmt.Println(index, a)
c <- true
}
</code>
并行示例2
<code>
package main
import (
"fmt"
"runtime"
"sync"
)
func main() {
runtime.GOMAXPROCS(runtime.NumCPU())
wg := sync.WaitGroup{}
wg.Add(10)
for i := 0; i < 10; i++ {
go Go(&wg, i)
}
wg.Wait()
}
func Go(wg *sync.WaitGroup, index int) {
a := 1
for i := 0; i < 1000000000; i++ {
a += i
}
fmt.Println(index, a)
wg.Done()
}
</code>
Select 示例
<code>
package main
import (
"fmt"
)
func main() {
c := make(chan int)
go func() {
for v := range c {
fmt.Println(v)
}
}()
for {
select {
case c <- 0:
case c <- 1:
}
}
}
</code>