并发篇-python协程

2019-07-18 11:00:21 浏览数 (3)

>>>使用进程池来实现并发服务器

# 通常可以分配2倍的 CUP 个数

>>>pool = ThreadPool(cpu_count()*2)

# 获取当前计算机的 CPU 核心个数

>>>n = cpu_count()

# 充分利用 CPU ,为每个 CPU 分配一个进程

>>>for i in range(n):

协程

线程是系统级别的,它们是由操作系统调度;

协程是程序级别的,由程序员根据需要自己调度。

我们把一个线程中的一个个函数叫做子程序,那么子程序在执行过程中可以中断去执行别的子程序;别的子程序也可以中断回来继续执行之前的子程序,这就是协程。

也就是说同一线程下的一段代码<1>执行着执行着就可以中断,然后跳去执行另一段代码,当再次回来执行代码块<1>的时候,接着从之前中断的地方开始执行。

>>>使用yield实现协程操作

>>>执行结果

如果某一个协程被网络阻塞了,那么整个线程(进程)都被阻塞。

协程本身不能避开阻塞。 任意时刻,只有一个协程在执行。

greenlet实现协程

Python的 greenlet就相当于手动切换,去执行别的子程序,在“别的子程序”中又主动切换回来。

# 切换到消费者,并将 item 传入消费者

>>>consumer.switch(item)

# 将一个普通函数变成协程

>>>consumer = greenlet(consumer)

# 让消费者先进入暂停状态(只有恢复时才能接受数据)

>>>consumer.switch()

0 人点赞