Go协程、并发、信道

Go 通过协程实现并发,协程之间靠信道通信

1.1 并发、并行是什么?

  • 并行其实很好理解,就是同时执行的意思,在某一时间点能够执行多个任务。
    想达到并行效果,最简单的方式就是借助多线程或多进程,这样才可在同一时刻执行多个任务。单线程是永远无法达到并行状态的。例,"合作并行开发某个项目"
  • 并发是在某一时间段内可以同时处理多个任务。我们通常会说程序是并发设计的,也就是说它允许多个任务同时执行,这个同时指的就是一段时间内。单线程中多个任务以间隔执行实现并发。例,我边听歌边写代码。

并行是指两个或者多个事件在同一时刻发生;而并发是指两个或多个事件在同一时间间隔内发生。

多线程或多进程是并行的基础,但单线程也通过协程实现了并发。

1.2 go协程是什么?

Go 协程是与其他函数或方法一起并发运行的函数或方法。Go 协程可以看作是轻量级线程。与线程相比,创建一个 Go 协程的成本很小。因此在 Go 应用中,常常会看到有数以千计的 Go 协程并发地运行。
Go 创建一个协程非常简单,只要在方法或函数调用之前加关键字 go 即可。

// 匿名协程
go func(){
}

1.3 Go 协程相比于线程的优势

  • 相比线程而言,Go 协程的成本极低。堆栈大小只有若干 kb,并且可以根据应用的需求进行增减。而线程必须指定堆栈的大小,其堆栈是固定不变的。
  • Go 协程会复用(Multiplex)数量更少的 OS 线程。即使程序有数以千计的 Go 协程,也可能只有一个线程。如果该线程中的某一 Go 协程发生了阻塞(比如说等待用户输入),那么系统会再创建一个 OS 线程,并把其余 Go 协程都移动到这个新的 OS 线程。所有这一切都在运行时进行,作为程序员,我们没有直接面临这些复杂的细节,而是有一个简洁的 API 来处理并发。
  • Go 协程使用信道(Channel)来进行通信。信道用于防止多个协程访问共享内存时发生竞态条件(Race Condition)。信道可以看作是 Go 协程之间通信的管道。

1.4 信道

1.4.1 声明信道

var c chan int          // 方式一,为nil,不能发送也不能接受数据
c := make(chan int)    // 方式二,可用

channel底层实现参考
channel是一个带缓冲,包含两个双向链表,分别是接受,发送消息。

1.4.2 信道使用[无缓冲信道]

c := make(chan int) // 写数据
c <- data

// 读数据
variable <- c  // 方式一
<- c              // 方式二,读出来的数据丢弃不使用

信道操作默认是阻塞的,往信道里写数据之后当前协程便阻塞,直到其他协程将数据读出。
一个协程被信道操作阻塞后,Go 调度器会去调用其他可用的协程,这样程序就不会一直阻塞。

func printHello(c chan bool) {
     fmt.Println("hello world goroutine")
     <- c    // 读取信道的数据
 }

 func main() {
     c := make(chan bool)
     go printHello(c)
     c <- true    // main 协程阻塞
    fmt.Println("main goroutine")

输出

hello world goroutine
main goroutine

1.4.3 死锁

前面提到过,读/写数据的时候信道会阻塞,调度器会去调度其他可用的协程。问题来了,如果没有其他可用的协程会发生什么情况?没错,就会发生著名的死锁。
最简单的情况就是,只往信道写数据。只读不写也会报同样的错误。

fatal error: all goroutines are asleep - deadlock!

1.4.4 关闭信道与 for loop

val, ok := <- channel
val 是接收的值,ok 标识信道是否关闭。为 true 的话,该信道还可以进行读写操作;为 false 则标识信道关闭,数据不能传输。
使用内置函数 close() 关闭信道。

使用 for range 读取信道,信道关闭,for range 自动退出。
使用 for range 一个信道,发送完毕之后必须 close() 信道,不然发生死锁。

func printNums(ch chan int) {
     for i := 0; i < 4; i++ {
         ch <- i
     }
     close(ch)
 }

 func main() {
     ch := make(chan int)
    go printNums(ch)

    for v := range ch {
        fmt.Println(v)
    }
}

输出

1   0
2   1
3   2
4   3

1.4.5 缓冲信道和信道容量

func main() {
     ch := make(chan int,3)

     ch <- 7
     ch <- 8
     ch <- 9
     //ch <- 10
     // 注释打开的话,协程阻塞,发生死锁
     会发生死锁:信道已满且没有其他可用信道读取数据

    fmt.Println("main stopped")
}

1.4.6 单向信道

之前创建的都是双向信道,既能发送数据也能接收数据。我们还可以创建单向信道,只发送或者只接收数据。
语法:

rch 是只发送信道,sch 是只接受信道。

rch := make(<-chan int)
sch := make(chan<- int)

这种单向信道有什么用呢?我们总不能只发不接或只接不发吧。这种信道主要用在信道作为参数传递的时候,Go 提供了自动转化,双向转单向

1.4.7 注意

链接参见

读写nil通道都会死锁

// 读nil通道:

var dataStream chan interface{}

<-dataStream

// 写nil通道:

var dataStream chan interface{}

dataStream <- struct{}{}

//都会死锁:

fatal error: all goroutines are asleep - deadlock!

close 值为nil的channel会panic:

var dataStream chan interface{}

close(dataStream)

panic: close of nil channel

1.4.8 Select

select 可以安全的将channels与诸如取消、超时、等待和默认值之类的概念结合在一起。
select看起来就像switch 包含了很多case,然而与switch不同的是:select块中的case语句没有顺序地进行测试,如果没有满足任何条件,执行不会自动失败,如果同时满足多个条件随机执行一个case。
类似witch
1、case分支中必须是一个IO操作:
2、当case分支不满足监听条件,阻塞当前case分支
3、如果同时有多个case分支满足,select随机选定一个执行(select底层实现,case对应一个Goroutine),
4、一次select监听,只能执行一个case分支,未执行的分支将被丢弃。通常将select放于for循环中。
5、default在所有case均不满足时,默认执行的分组,为了防止忙轮询,通常将for中select中的default省略。

【结论】使用select的Goroutine,与其他Goroutine间才用异步通信。

原文地址:https://www.cnblogs.com/ExMan/p/12264120.html

时间: 2024-10-10 07:59:19

Go协程、并发、信道的相关文章

windows下多进程加协程并发模式

好久没更新博客了.正好最近要整理一下最近这段时间做过的项目以及学习python的一些心得.如标题所示,今天就来说说windows下多进程加协程并发模式.其实网上还是蛮多在linux下的多进程加协程并发模式,本身linux对python的支持更好吧.但是由于本人的开发环境是windows的,而且网上关于这方面的资料还是少了一点,不过经过一番折腾,也算是弄出来了.废话不多说,先贴代码吧: # coding=utf-8 # windows下多进程加协程并发模式 # 打入gevent的monkey补丁

Python多任务实现 之协程并发下载多图片

协程是Python中实现多任务一种方式,相比多任务之进程和线程,协程不需要消耗过多的资源,更高效的利用了cpu资源. 在Python中通过gevent封装generator迭代器功能实现多任务的切换.协程在运行过程中是靠程序的耗时操作来实现程序中断.达到切换多任务.至始至终,程序都是在一条主线程里面完成的. 下面是一个利用协程实现多张图片的同时下载. from gevent import monkey import gevent import urllib.request # 设置识别耗时操作

并发编程 - 协程 - 1.协程概念/2.greenlet模块/3.gevent模块/4.gevent实现并发的套接字通信

1.协程并发:切+保存状态单线程下实现并发:协程 切+ 保存状态 yield 遇到io切,提高效率 遇到计算切,并没有提高效率 检测单线程下 IO行为 io阻塞 切 相当于骗操作系统 一直处于计算协程:...单线程下实现并发:根本目标:遇到IO就切,一个线程的整体IO降下来程序用的cpu 时间长,就叫执行效率高效率最高:多个进程 (多个cpu) 每个进程开多个线程 每个线程用到协程 (IO就切)总结协程特点: 1 #并发执行 2 import time 3 4 def producer(): 5

基于协程的Python网络库gevent

import gevent def test1(): print 12 gevent.sleep(0) print 34 def test2(): print 56 gevent.sleep(0) print 78 gevent.joinall([ gevent.spawn(test1), gevent.spawn(test2), ]) 解释下,"gevent.spawn()"方法会创建一个新的greenlet协程对象,并运行它."gevent.joinall()"

python之协程

协程,又称微线程,纤程.英文名Coroutine.协程是一种用户态的轻量级线程. 所谓用户态就是说协程是由用户来控制的,CPU不认识协程,协程是跑在线程中的. 协程拥有自己的寄存器上下文栈.协程调试切换时,将寄存器上下文栈保存到其他地方,在切回来时,恢复先前保存的寄存器上下文栈. 因此,协程能保留上一次调用时的状态(即所有局部状态的一个特定组合),每次过程重入时,就相当于进入上一次调用的状态,也就是进入上一次离开时所处逻辑流的位置. 线程切换时会将上下文和栈保存到CPU的寄存器中. 协程的标准定

Python开发基础--- 进程间通信、进程池、协程

进程间通信 进程彼此之间互相隔离,要实现进程间通信(IPC),multiprocessing模块支持两种形式:队列和管道,这两种方式都是使用消息传递的. 进程队列queue 不同于线程queue,进程queue的生成是用multiprocessing模块生成的. 在生成子进程的时候,会将代码拷贝到子进程中执行一遍,及子进程拥有和主进程内容一样的不同的名称空间. 示例1: 1 import multiprocessing 2 def foo(): 3 q.put([11,'hello',True]

python基础之进程间通信、进程池、协程

进程间通信 进程彼此之间互相隔离,要实现进程间通信(IPC),multiprocessing模块支持两种形式:队列和管道,这两种方式都是使用消息传递的. 进程队列queue 不同于线程queue,进程queue的生成是用multiprocessing模块生成的. 在生成子进程的时候,会将代码拷贝到子进程中执行一遍,及子进程拥有和主进程内容一样的不同的名称空间. 示例1: 1 import multiprocessing 2 def foo(): 3 q.put([11,'hello',True]

Python线程和协程-day10

写在前面 上课第10天,打卡: 感谢Egon老师细致入微的讲解,的确有学到东西! 一.线程 1.关于线程的补充 线程:就是一条流水线的执行过程,一条流水线必须属于一个车间: 那这个车间的运行过程就是一个进程: 即一个进程内,至少有一个线程: 进程是一个资源单位,真正干活的是进程里面的线程: 线程是一个执行单位: 多线程:一个车间内有多条流水线,多个流水线共享该车间的资源: 一个进程内有多个线程,多线程共享一个进程的资源: 线程创建的开销要远远小于创建进程的开销: 进程之间更多的是一种竞争关系:

谈谈对协程的理解

什么是协程 协程是在线程之上由“用户”构建的并发单元,对OS来说无感知,协程的切换由用户自己管理和调度.(这里的用户是相较于内核而言的,一些通用库这里也理解为用户) C/C++怎么实现协程 作为一个C++后台开发,我知道像go, lua之类的语言在语言层面上提供了协程的api,但是我比较关心C++下要怎么实现这一点,下面的讨论都是从C/C++程序员的角度来看协程的问题的. boost和腾讯都推出了相关的库,语言层面没有提供这个东西.我近期阅读了微信开源的libco协程库,协程核心要解决几个问题: