Python异步编程之协程任务的调度操作实例分析
本文实例讲述了Python异步编程之协程任务的调度操作。分享给大家供大家参考,具体如下:
我们知道协程是异步进行的,碰到IO阻塞型操作时需要调度其他任务,那么这个调度规则或者是算法是怎样的呢?现在有以下几个疑问:
1、多个任务准备好,需要运行时,优先执行哪一个?
2、一个任务运行时,如果别的任务准备好了,是否需要中断当前任务呢?
在网上找了很多资料,也无法找到相关的资料,于是编写了几个简单的程序,查看任务的执行过程。
根据Python的asyncio我们可以编写一个简单的程序:
importasyncio asyncdefa(x): whilex>0: print('a:',x) awaitasyncio.sleep(0.5) x-=1 asyncdefb(x): whilex>0: print('b:',x) awaitasyncio.sleep(1.8) x-=1 asyncdefc(x): whilex>0: print('c:',x) awaitasyncio.sleep(1.5) x-=1 loop=asyncio.get_event_loop() tasks=[a(2),b(2),c(2)] loop.run_until_complete(asyncio.wait(tasks)) loop.close()
我们创建一个loop事件,把a,b,c3个函数加入到任务中,用asyncio.sleep(1)来切换运行其他程序。运行结果如下:
b:2
c:2
a:2
a:1
c:1
b:1
这里一直有一个疑问,开始运行任务时,3个任务同时准备好,为什么执行顺序是b,a,c。
我们分析一下函数的执行过程,先执行b,然后阻塞,执行c,阻塞,再执行a,阻塞。函数调用过程是b->c->a,0.5s过后a完成,1.5s过后c完成,1.8s过后b完成。
修改睡眠时间,我们可以测试出很多情况,最后得出了任务调度的规则,可能有一些地方总结的不对,欢迎大家来指正。
1、初始化,asyncio把需要执行的任务加入到任务队列中。
2、从队首拿出一个任务来运行,如果任务被阻塞,则拿另一个任务队列,在任务切换是需要保存每个任务的工作环境。
3、把IO的完成,定时时间到的时间加入到事件队列,从队首中拿出事件去唤醒相应的任务。
好像看起来很简单,又有点像操作系统,又有点像中断,但是操作系统是感知不到它的存在,更没有调用中断了。这里我们要注意,加入有一个任务正在运行,同时有一个事件发生,asyncio是不会中断当前任务的,而是等这个任务碰到了阻塞才会处理这个事件,所以编程时需要把任务分的很细,尽量不要让任务执行过长的时间。
更多关于Python相关内容感兴趣的读者可查看本站专题:《Python进程与线程操作技巧总结》、《Python数据结构与算法教程》、《Python函数使用技巧总结》、《Python字符串操作技巧汇总》、《Python入门与进阶经典教程》、《Python+MySQL数据库程序设计入门教程》及《Python常见数据库操作技巧汇总》
希望本文所述对大家Python程序设计有所帮助。
声明:本文内容来源于网络,版权归原作者所有,内容由互联网用户自发贡献自行上传,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任。如果您发现有涉嫌版权的内容,欢迎发送邮件至:czq8825#qq.com(发邮件时,请将#更换为@)进行举报,并提供相关证据,一经查实,本站将立刻删除涉嫌侵权内容。