Golang sync简述

Golang sync模块

• sync.map类型是在Go1.9加入的，实现的是一个线程安全的map,它和map在使用上有着多方面的不同
  • 首先是定义上不需要使用make来创建内存资源，而是直接定义后使用如:var syncMap sync.Map
  • syncMap.Load(key)(value,ok)，Load是sync.Map中获取Value的方法，在sync.Map中key，value都是interface{}
  • syncMap.Store(key,value)存
  • syncMap.Range(f func(key, value interface{}) bool)用于遍历sync.Map对象如：

      f := func(k, v interface{}) bool {
      		log.Println(k, v)
      		return true
      	}
      	syncMap.Range(f)
      }
  

  • sync.Delete(key)删除
• sync.WaitGroup是协程控制中比较方便的一个，相当于一个监视器；当主程序中检测到计数器为为0时则结束，它包含三个方法：
  • Add()方法用于设定初始的协程数，或者说监听的协程数
  • Done()方法将计数器减一,Done与Add()应当是对应的，过多导致计数器为负直接炸，过少则所有协程结束时检测到还在wait也炸
  • Wait()一般是主程序等待，当Done完所有的协程则Wait()结束不再阻塞

      func main(){
      var waitgrup sync.WaitGroup
      waitgrup.Add(5)
      go func(waitgrup){
      do someting
      defer waitgrup.Done()
      }
      go func()
      ...
      waitgrup.Wait()//等待所有监听的协程完成
      }
      
  

• sync.Mutex 用于锁机制的实现还有读写锁sync.RWMutex这个没什么好说的就是Lock()和Unlock()
• sync.Pool 复用池，因为Go含有GC因此很多情况下为了复用变量需要将它们暂存起来而不用背回收掉
  ，但是Pool中也是包含GC的一般在两次GC之间清理一次Pool。因此Pool中的变量是有肯能被清除的。

        var pool = &sync.Pool{New: func() interface{} {
    		return make([]byte, 10)
    	}}//实例化时的方法实际是当pool为空时创建一个对象返回，如果pool空return一个新的[]byte
    	value:= pool.Get()//从pool中取一个对象
    	pool.Put(value)//用完将将对象放回

sync.Once用于只需要执行一次的操作中，比如说初始化操作只需要在程序执行时执行一次
它含有一个Do()方法，将函数作为参数传递给它能保证其只执行一次，实现原理：

func (o *Once) Do(f func()) {
	if atomic.LoadUint32(&o.done) == 1 {
		return
	}
	// Slow-path.
	o.m.Lock()
	defer o.m.Unlock()
	if o.done == 0 {
		defer atomic.StoreUint32(&o.done, 1)
		f()
	}
}
//使用原子操作计数并上锁

• sync.Cond用于锁的管理，用于多个协程的同步

    var cond=sync.NewCond(sync.Mutex)
    cond.L.Lock()
    cond.L.UnLock()
    cond.wait()//以上分别是获取锁，释放锁，wait()等待广播或者signal并阻塞当前协程
    Cond.Signal()发送一个通知给阻塞中的协程
    Cond.Broadcast()广播给所有wait的协程，

具体案例：

func TestCond() {
	var locker = new(sync.Mutex)
	var cond = sync.NewCond(locker)
	for i := 0; i < 10; i++ {
		go func(v int) {
			log.Printf("%v start\n", v)
			cond.L.Lock()
			log.Println("lock")
			defer cond.L.Unlock()
			cond.Wait()//等待Signal,阻塞
			log.Printf("Finish %v\n", v)
			time.Sleep(time.Second)
		}(i)
	}
	time.Sleep(time.Second)
	log.Println("Going to distribute signal")
	cond.Signal()
	time.Sleep(time.Second * 3)
	log.Println("Broadcast")
	cond.Broadcast()
	time.Sleep(15 * time.Second)
}//Cond参考博客:https://blog.51cto.com/qiangmzsx/2106461