GO 语言中的操作系统线程和goroutine的关系
- 一个操作系统线程对应用户态多个goroutine
- go程序可以同时使用多个操作系统线程
- goroutine和系统线程事多对多的关系，即m:n
Go语言的并发模型是CSP （Communicating Sequential Processes）提倡通过通信共享内存而不是通过共享内存而实现通信，引出了channel
什么场景下使用channel合适呢？
通过全局变量加锁同步来实现通讯，并不利于协程对全局变量的读写操作。加锁虽然可以解决goroutine对全局变量的抢占资源问题，但是影响性能，违背了原则。
总结：为了解决上述的问题，我们可以引入channel，使用管道进行协程goroutine间的通信。
管道channel使用示例
for range从管道中取值，通道关闭时for range退出
package main
import "fmt"
func main() {
ch1 := make(chan int)
ch2 := make(chan int)
//开启goroutine 把0-100写入到ch1管道中
go func() {
for i := 0; i < 100; i++ {
ch1<-i
}
close(ch1)
}()
//开启goroutine 从ch1管道中取值，值的平方赋值给ch2
go func() {
for {
i,ok := <-ch1
if ok {
ch2<- i*i
}else {
break
}
}
close(ch2)
}()
//主goroutine从ch2管道中取出，打印
for i := range ch2 {
fmt.Println(i)
}
}
channel升级，单通道，只读通道和只写通道
package main
import "fmt"
func main() {
ch1 := make(chan int)
ch2 := make(chan int)
go counter(ch1)
go square(ch2,ch1)
output(ch2)
}
func counter(in chan<- int) {
defer close(in)
for i := 0; i < 100; i++ {
in<-i
}
}
func square(in chan<- int, out <-chan int) {
defer close(in)
for i := range out {
in <- i*i
}
}
func output(out <-chan int) {
for i:= range out{
fmt.Println(i)
}
}
goroutine work pool 可以防止goroutine泄露
package main
import (
"fmt"
"time"
)
func main() {
jobs := make(chan int, 100)
results := make(chan int, 100)
//开启3个goroutine
for i := 1; i < 3; i++ {
go worker(i,jobs,results)
}
//5个任务
for j := 1; j <=5 ; j++ {
jobs <- j
}
close(jobs)
//输出结果
for a := 1; a <=5; a++ {
<-results
}
}
func worker(id int, jobs <-chan int, results chan<- int) {
for j := range jobs {
fmt.Printf("worker:%d start job:%d\n",id,j)
time.Sleep(time.Second)
fmt.Printf("worker:%d end job:%d\n",id,j)
results <- j*2
}
}
goroutine使用select case多路复用，满足我们同时从多个通道接收值的需求
//使用select语句能提高代码的可读性。
//可处理一个或多个channel的发送/接收操作。
//如果多个case同时满足，select会随机选择一个。
//对于没有case的select{}会一直等待，可用于阻塞main函数。
ch := make(chan int, 1)
go func() {
for i := 0; i < 10; i++ {
select {
case x := <-ch:
fmt.Println(x)
case ch <- i:
}
}
}()
goroutine 加锁
var x int64
var wg sync.WaitGroup
//添加互斥锁
var lock sync.Mutex
func main() {
wg.Add(2)
go add()
go add()
wg.Wait()
fmt.Println(x)
}
func add() {
for i := 0; i < 5000; i++ {
lock.Lock() //加锁
x = x + 1
lock.Unlock() //解锁
}
wg.Done()
}