标签：注意 eve com pytho 中断 创建 ret get 计算机
import asyncio @asyncio.coroutine def aa(x): print (‘1‘) b=yield from x print (b) @asyncio.coroutine def bb(): print (‘2‘) yield print (‘3‘) return 4 x=bb() loop = asyncio.get_event_loop() loop.run_until_complete(aa(x)) loop.close()
以上能揭示由asyncio模块创建的携程的运行过程
用asyncio提供的@asyncio.coroutine可以把一个generator标记为coroutine类型，然后在coroutine内部用yield from调用另一个coroutine实现异步操作
以上代码，携程aa和携程bb共同组成一个携程池，首先aa执行，打印1，执行到yield的时候产生中断，计算机转而随机执行携程池内其他的携程，因为这里只有两个携程，所以就执行bb，打印2，产生中断，而这时，携程池内全部的携程都产生中断，已经没有可执行的携程了，那么计算机并不会永远中断下去，而是逐个跨过各个携程的yield去执行完携程内剩余的代码。又因为，aa的再次执行需要等待bb执行完毕的返回(yield from x)，那么bb永远是先于aa执行完毕的。这样就打印了3，然后返回给携程aa一个4，aa随即打印4
关于携程池的概念，请看这一个例子
import asyncio @asyncio.coroutine def d(): print (‘d‘) yield print (‘end‘) @asyncio.coroutine def e(): print (‘e‘) yield @asyncio.coroutine def f(): print (‘f‘) yield @asyncio.coroutine def g(): print (‘g‘) yield @asyncio.coroutine def h(): print (‘h‘) yield @asyncio.coroutine def j(): print (‘j‘) yield loop = asyncio.get_event_loop() tasks = [d(),e(),f(),g(),h(),j()] loop.run_until_complete(asyncio.wait(tasks)) loop.close()
‘‘‘
f
d
j
h
g
e
end
‘‘‘
注意end永远是最后打印的，这更加说明了，只有在携程池内所有携程全部都处于中断的时候，计算机就会跨过携程内的yield执行携程内剩余代码
标签：注意 eve com pytho 中断 创建 ret get 计算机
原文地址：https://www.cnblogs.com/saolv/p/9302423.html
