您现在的位置是:首页 > 学习笔记 > Go语言Go语言

Go并发

冰山2019-02-14【Go语言】人已围观

简介1.并发
1.1并发概述
1.2进程并发
1.3线程并发
1.4协程并发
1.5Go并发
2.Goroutine
2.1Goroutine定义
2.2Goroutine的创建
2.3Goroutine特性
3.channel管道
3.1定义channel变量
3.2无缓冲的channel
3.3有缓冲的channel
3.4关闭channel
4.读写锁与互斥锁
4.1死锁
4.2互斥锁
4.3读写锁



3)在第 3 步,右侧的 goroutine 将它的手放入通道,这模拟了从通道里接收数据。这个 goroutine 一样也会在通道中被锁住,直到交换完成。

4)在第 4 步和第 5 步,进行交换,并最终,在第 6 步,两个 goroutine 都将它们的手从通道里拿出来,这模拟了被锁住的 goroutine 得到释放。两个 goroutine 现在都可以去做其他事情了。无缓冲的channel创建格式:

    make(chan Type)   //等价于make(chan Type, 0)

如果没有指定缓冲区容量,那么该通道就是同步的,因此会阻塞到发送者准备好发送和接收者准备好接收。

示例:
package main

import (
   "fmt"
)

func main() {
   c := make(chan int, 0) //创建无缓冲的通道 c

    //内置函数 len 返回未被读取的缓冲元素数量,cap 返回缓冲区大小
   fmt.Printf("len(c)=%d, cap(c)=%d\n", len(c), cap(c))

   go func() {
      defer fmt.Println("子go程结束")

      for i := 0; i < 3; i++ {
         c <- i
         fmt.Printf("子go程正在运行[%d]: len(c)=%d, cap(c)=%d\n", i, len(c), cap(c))
      }
   }()
   for i := 0; i < 3; i++ {
      num := <-c //从c中接收数据,并赋值给num
      fmt.Println("num = ", num)

   }

   fmt.Println("main进程结束")
}

输出结果:
len(c)=0, cap(c)=0
子go程正在运行[0]: len(c)=0, cap(c)=0
num =  0
num =  1
子go程正在运行[1]: len(c)=0, cap(c)=0
子go程正在运行[2]: len(c)=0, cap(c)=0
子go程结束
num =  2
main进程结束

Process finished with exit code 0
 

3.3有缓冲的channel


有缓冲的通道(buffered channel)是一种在被接收前能存储一个或者多个数据值的通道。这种类型的通道并不强制要求 goroutine 之间必须同时完成发送和接收。通道会阻塞发送和接收动作的条件也不同。

只有通道中没有要接收的值时,接收动作才会阻塞。只有通道没有可用缓冲区容纳被发送的值时,发送动作才会阻塞。

这导致有缓冲的通道和无缓冲的通道之间的一个很大的不同:无缓冲的通道保证进行发送和接收的 goroutine 会在同一时间进行数据交换;有缓冲的通道没有这种保证。

示例图如下:



1)在第 1 步,右侧的 goroutine 正在从通道接收一个值。
2)在第 2 步,右侧的这个 goroutine独立完成了接收值的动作,而左侧的 goroutine 正在发送一个新值到通道里。
3)在第 3 步,左侧的goroutine 还在向通道发送新值,而右侧的 goroutine 正在从通道接收另外一个值。这个步骤里的两个操作既不是同步的,也不会互相阻塞。
4)最后,在第 4 步,所有的发送和接收都完成,而通道里还有几个值,也有一些空间可以存更多的值。

有缓冲的channel创建格式:
    make(chan Type, capacity)

如果给定了一个缓冲区容量,通道就是异步的。只要缓冲区有未使用空间用于发送数据,或还包含可以接收的数据,那么其通信就会无阻塞地进行。
借助函数 len(ch) 求取缓冲区中剩余元素个数, cap(ch) 求取缓冲区元素容量大小。

示例:

package main

import (
   "fmt"
)

func main() {
   c := make(chan int, 3) //带缓冲的通道

   //内置函数 len 返回未被读取的缓冲元素数量, cap 返回缓冲区大小
   fmt.Printf("len(c)=%d, cap(c)=%d\n", len(c), cap(c))

   go func() {

 4/7   首页 上一页 2 3 4 5 6 7 下一页 尾页

  • 微信扫一扫~
  • 支付宝扫一扫~

很赞哦! ()

上一篇:面向对象

下一篇:Golang之网络编程

相关文章

文章评论

本站推荐