面试 协程

Posted 2020-11-23 fan-1994716

协程（corouutine）：轻量级的线程，不存在上下文切换，能在多个任务之间调度的多任务方式，可以使用，yield实现

线程和进程的操作是由程序触发系统接口，最后的执行者是系统，它本质上是操作系统提供的功能。而协程的操作则是程序员指定的，在python中通过yield，人为的实现并发处理。

协程存在的意义：对于多线程应用，CPU通过切片的方式来切换线程间的执行，线程切换时需要耗时。协程，则只使用一个线程，分解一个线程成为多个“微线程”，在一个线程中规定某个代码块的执行顺序。

协程的适用场景：当程序中存在大量不需要CPU的操作时（IO）。

 

简单多任务协程实列：

import time
import threading
def task_1():
    print(threading.current_thread())
    while True:

        print(‘---1---‘)
        time.sleep(1)
        yield
def task_2():
    print(threading.current_thread())
    while True:

        print(‘---2---‘)
        time.sleep(1)
        yield
def main():
    t1=task_1()
    t2=task_2()
    while True:
        next(t1)
        next(t2)
if __name__ == ‘__main__‘:
    main()

 

在不需要自己“造轮子”的年代，同样有第三方模块为我们提供了高效的协程，这里介绍一下greenlet和gevent。本质上，gevent是对greenlet的高级封装，因此一般用它就行，这是一个相当高效的模块。

在使用它们之前，需要先安装，可以通过源码，也可以通过pip。

 

greenlet

def test1():
    print(12)
    gr2.switch()
    print(34)
    gr2.switch()


def test2():
    print(56)
    gr1.switch()
    print(78)


gr1 = greenlet(test1)
gr2 = greenlet(test2)
gr1.switch()

gevent

from gevent import monkey; monkey.patch_all()
import gevent
import requests
 
def f(url):
 print(‘GET: %s‘ % url)
 resp = requests.get(url)
 data = resp.text
 print(‘%d bytes received from %s.‘ % (len(data), url))
 
gevent.joinall([
  gevent.spawn(f, ‘https://www.python.org/‘),
  gevent.spawn(f, ‘https://www.yahoo.com/‘),
  gevent.spawn(f, ‘https://github.com/‘),
])