Golang语言中,进程间通信除了使用channel,还可以使用共享内存,即sync包。

Q-1

  上面的代码毫无疑问的只会输出:“主goroutine执行结束”,而不会输出子goroutine执行结束,这是因为,主协程一旦执行完毕,整个进程就会结束。

  

sync组等待

  sync包中常用的有三个方法:Add(num int) 、 Done()、 Wait()

  sync中会在内部维持一个类似于计数器的东西,通过Add方法来增加计数器的值,增加参数num;通过Done来减少计数器的值,一次只能减少1;Wait方法会使主协程阻塞,只有到内部计数器的值为0时,阻塞才会解开。

  用法如下:

  注意:添加的计时器数量必须比减少计时器的数量要少,否则会引发死锁。

  比如,将计数器值增加了10,但是只执行了9次计数器减少,剩余一个计数器,计数器的值始终不为0,则主协程一直等待,形成死锁。但是较少计数器的次数可以比计数器的值要大,可以提前结束主协程的阻塞。

  

Q-2

  请看下面一段代码,尝试在两个循环中,各自使sum加1,执行1000次,乍一看,觉得结果是sum的最终结果是2000,但是真正执行之后,结果不是2000。

  

sync互斥锁

  sync互斥锁有两个常用的方法,Lock()加锁,Unlock()解锁。使用Lock加锁后,不能再进行加锁,只有当对其进行Unlock解锁之后,才能对其加锁。这个很好理解。

  如果对一个未加锁的资源进行解锁,会引发panic异常。

  可以在一个goroutine中对一个资源加锁,而在另外一个goroutine中对该资源进行解锁。

  使用示例如下:

  

sync读写互斥锁(多读单写锁)

  允许对同一资源进行同时读,但是不能进行同时写,也不能进行一边读,一边写。

  如果一个资源被加了写锁,那么就不能再给他加其他锁,包括写锁,只能等写锁解开后,才能继续加其他锁。如果一个资源被加了读锁,那么,仍然可以给该资源加读锁,但是不能加写锁,必须等读锁释放后,才能加写锁。

  sync.RWMutex有四个常用的方法:

    Lock()加写锁  、 Unlock()取消写锁 、 RLock()加读锁 、 RUnlock()释放读锁

  使用示例:

  运行之后,就会发现,只有一个写加锁,只有写解锁之后,才允许加其他锁;如果是加读锁之后,可以再加读锁。

 

Q-3

  这个示例代码运行之后,会输出10次“运行demo函数”,因为有10个goroutine,每个goroutine都运行了1次。

  现在的需求是:虽然有10个goroutine,但是希望只有一个goroutine中执行demo函数,如果一个goroutine执行过了demo函数,其他的goroutine就会忽略demo函数,不去执行demo,保证demo函数只被执行一次。

 

sync.once初始化

  sync.Once就是用来解决上面这个问题的:Once的作用就是多次调用,但只执行一次,Once只有一个方法->Once.Do(func),向Do中传入一个函数,在第一次执行Once.Do()的时候,才执行传入的func,以后在执行Once.Do(),就不会再执行传入的func。

  示例如下:

  这样就不会执行多次demo(),而只输出一次“运行demo函数”