并发和并行的区别#

goroutine的启动#

将要并发执行的任务包装成一个函数，调用函数的时候前面加上go关键字，就能够开启一个goroutine去执行该函数的任务。

goroutine对应的函数执行完，该goroutine就结束了。

程序启动的时候会自动的创建一个goroutine去执行main函数

main函数结束了，那么程序就结束了，由该程序启动的所有其他goroutine也都结束了。

goroutine的本质#

goroutine的调度模型：GMP

M:N：把m个goroutine分配给n个操作系统线程。

goroutine与操作系统线程（OS线程）的区别#

goroutine是用户态的线程，比内核态的线程更轻量级一点，初始时只占用2KB的栈空间。

可以轻松开启数十万的goroutine也不会崩内存。

runtime.GOMAXPROCS#

Go1.5之后默认就是操作系统的逻辑核心数，默认跑满CPU

runtime.GOMAXPROCS(1):只占用一个核。

work pool模式#

开启一定数据的goroutine去干活。

sync.WaitGroup#

var wg sync.WaitGroup

• wg.Add(1) ：计数器+1
• wg.Done()：计数器-1
• wg.Wait()：等

为什么需要channel?#

通过channel实现多个goroutine之间的通信。

CSP:通过通信来共享内存。

channel是一种类型，一种引用类型。make函数初始化之后才能使用。（slice、map、channel）

channel的声明#

var ch chan 元素类型

channel的初始化#

ch = make(chan 元素类型, [缓冲区大小])

channel的操作#

• 发送：ch <- 100
• 接收：x := <- ch
• 关闭: close(ch)

带缓冲区的通道和无缓冲区的通道：#

快递员送快递的示例，有缓冲区就是有快递柜。

从通道中取值：#

1
for {
2
  x, ok := <-results
3
  if !ok { // 什么时候ok=false? results被关闭的时候
4
    break
5
  }
6
  fmt.Println(x)
7
}
8

9
for x := range results {
10
  fmt.Println(x)
11
}

单项通道：#

通常是用做函数的参数，只读通道<-chan int和只写通道chan<- int

通道的各种考虑情况：#

sync.Mutex 互斥锁#

适用于并发访问公共资源的场景。

声明互斥锁

1
var lock sync.Mutex

使用互斥锁

1
func add() {
2
  for i := 0; i < 500000; i++ {
3
    lock.Lock()
4
    x = x + 1
5
    lock.Unlock()
6
  }
7
  wg.Done()
8
}

sync.RWMutex 读写互斥锁#

适用于读远远大于写的场景。

声明读写互斥锁

1
var rwLock sync.RWMutex

使用读写互斥锁

1
// 读操作
2
func read() {
3
  defer wg.Done()
4
  rwLock.RLock()
5
  fmt.Println(x)
6
  time.Sleep(time.Millisecond * 2)
7
  rwLock.RUnlock()
8
}
9

10
// 写操作
11
func write() {
12
  defer wg.Done()
13
  rwLock.Lock()
14
  x = x + 1
15
  time.Sleep(time.Millisecond * 10)
16
  rwLock.Unlock()
17
}

sync.Once#

适用于那些只执行一次的场景。

例如，只加载一次图片、只关闭一次channel

sync.Map#

Go内置的map不是并发安全的。

1
// sync.Map 是一个开箱即用的并发安全的map
2

3
var m2 = sync.Map{}
4

5
func main() {
6
  wg := sync.WaitGroup{}
7
  for i := 0; i < 21; i++ {
8
    wg.Add(1)
9
    go func(n int) {
10
      key := strconv.Itoa(n)
11
      m2.Store(key, n)         // 必须使用sync.Map内置的Store方法设置键值对
12
      value, _ := m2.Load(key) // 必须使用sync.Map提供的Load方法根据key取值
13
      fmt.Printf("k=:%v,v:=%v\n", key, value)
14
      wg.Done()
15
    }(i)
16
  }
17
  wg.Wait()
18
}

atomic#

网络编程#

互联网协议#

TCP客户端和服务端#

TCP黏包#

UDP客户端和服务端#

引申知识点:

大端和小端