go并发语句的基本使用

迷南。 2022-10-10 12:55 141阅读 0赞

### 文章目录 ###

*  背景
 *  goroutine基本使用
 *   *  chan
     *  select
     *  close
 *  死锁
 *  互斥锁 sync.Mutex
 *   *  基本使用
     *  隐患
 *  读写锁 sync.RWMutex
 *   *  基本使用

# 背景 #

> 不要通过共享内存来通信，而要通过通信来共享内存

**协程**

golang 中提供 goroutine（协程）机制，写成和操作系统线程并无一对一关系，协程工作在相同的地址空间，go 中通过 channel 来同步协程，协程不是由操作系统内核来控制，而是完全由程序来控制

channel 中如果ch中的数据无人接收，就无法再给通道传入其他数据，即 channel 只能接收一个数据，再接收就会被阻塞，被等待输出

无缓冲的 channel 通道在接收或者释放数据时候所在协程会被阻塞，有缓冲通道在接收或者释放数据时候所在协程不会被阻塞

**竞态与竞态条件**

golang 中 2 或多个协程竞争同一资源时候称为竞态，如果这些协程对访问同一资源的顺序敏感，那么就称这些写成存在竞态条件

**关于信道和锁机制**

在 golang 中信道地位很高，面对并发编程有限考虑使用信道，如果信道没法解决的，那只能依靠 golang 中的锁机制了

# goroutine基本使用 #

## chan ##

下面展示的是一个很常规的使用 goroutine 协程配合 channel 的例子

// 经常见到的使用 go 关键词还有 chan 变量的例子
    func main() {
        
      c := make(chan int)
      for i := 0; i < 5; i++ {
        
        // 循环开启 5 个 生产者，共用 c 一个通道空间
        go foo(i, c)
      }
      // 1 个消费者，消费 c 空间
      for i := 0 ; i < 5; i++ {
        
        fmt.Println(<-c)
      }
    }
    
    func foo(i int, c chan int) {
        
      time.Sleep(time.Second)
      c <- i
    }

## select ##

select case 常常作为选择判断当前时候该 “select” 哪个通道，也就是哪个 case 来进行操作，因为当下时刻可能会有一些通道的数据还没有填充，但是通道接收者又等着接收数据，因此会被阻塞

select {
        
      case 通过操作:
      	// ...
      case 通道操作:
      	// ...
    }

## close ##

通过 close 方法来关闭通道，这样通道就无法再写入任何值，如果再写入就会 panic，读取已经关闭的通道会获得一个与通道类型对应的零值

// 关闭通道 c
    close(c)
    v, ok := <- c
    if !ok {
        
      fmt.Println("通道已经关闭了！")
    }

# 死锁 #

一个或多个 goroutine 被阻塞后永远无法解除阻塞状态就被称为死锁。引发死锁的程序可能会非常简单，死锁虽然很难杜绝但是可以通过一些简单的规则来让我们创建出不会死锁的代码

// 死锁代码
    func main() {
        
    	c := make(chan int)
    	<- c 
    }

在使用 golang 的互斥锁时候是有可能触发死锁的，比如说 1 协程用互斥锁 A 锁住 m 变量，然后 1 协程执行，发现 n 变量被 B 互斥锁锁住了，要想使用 n 变量就要等待 2 协程释放互斥锁 B，但是 2 协程也很难，因为 2 协程此时正等待 m 变量的释放，这样它才能释放 n…

# 互斥锁 sync.Mutex #

## 基本使用 ##