实操python3.6当中的异步IO( asyncio) 协程

2022-09-18 14:38:25

我们的自动化部署平台升级到django2+python3了,

并发方面的知识点,也跟进一下啦。


http://python.jobbole.com/87310/

这篇讲得挺入门的~~

实操一下。


4746728e1e748b896b295086434a13fc7a3ba956



import time
import asyncio
import functools

now = lambda : time.time()

async def do_some_work(x):
    print('Waiting: ', x)
    await asyncio.sleep(x)
    return 'Done after {}s'.format(x)
def callback(t, future):
    print('Callback: ', t, future.result())

start = now()

coroutine1 = do_some_work(1)
coroutine2 = do_some_work(2)
coroutine4 = do_some_work(4)


tasks = [
    asyncio.ensure_future(coroutine1),
    asyncio.ensure_future(coroutine2),
    asyncio.ensure_future(coroutine4),
    ]


loop =asyncio.get_event_loop()

for task in tasks:
    task.add_done_callback(functools.partial(callback, 2))

loop.run_until_complete(asyncio.wait(tasks))

for task in tasks:
    task.add_done_callback(functools.partial(callback, 2))
    print('Task return: {}'.format(task.result()))


print('TIME: ', now() - start)


  • 作者:weixin_33946020
  • 原文链接:https://blog.csdn.net/weixin_33946020/article/details/90192294
    更新时间:2022-09-18 14:38:25