與事件循環(huán)進行交互，最基本的方式就是任務，任務封裝了協(xié)程和自動跟蹤它的狀態(tài)。任務是Future類的子類，所以其它協(xié)程可以等待任務完成，或當這些任務完成獲取返回結果。

在這里通過create_task()函數(shù)來創(chuàng)建一個任務實例，然后事件循環(huán)就運行這個任務，直到這個任務返回為止：

import asyncio async def task_func(): print(’in task_func’) return ’the result’ async def main(loop): print(’creating task’) task = loop.create_task(task_func()) print(’waiting for {!r}’.format(task)) return_value = await task print(’task completed {!r}’.format(task)) print(’return value: {!r}’.format(return_value)) event_loop = asyncio.get_event_loop()try: event_loop.run_until_complete(main(event_loop))finally: event_loop.close()

結果輸出如下：

creating taskwaiting for <Task pending coro=<task_func() running at D:workcsdnpython_Game1exampleasyncio_create_task.py:4>>in task_functask completed <Task finished coro=<task_func() done, defined at D:workcsdnpython_Game1exampleasyncio_create_task.py:4> result=’the result’>return value: ’the result’

補充知識：python里創(chuàng)建任務執(zhí)行一半時取消任務執(zhí)行

下例子來演示創(chuàng)建任務執(zhí)行一半時取消任務執(zhí)行，這時會拋出異常CancelledError，同時也提供了一個機會來刪除占用資源等等：

import asyncio async def task_func(): print(’in task_func, sleeping’) try: await asyncio.sleep(1) except asyncio.CancelledError: print(’task_func was canceled’) raise return ’the result’ def task_canceller(t): print(’in task_canceller’) t.cancel() print(’canceled the task’) async def main(loop): print(’creating task’) task = loop.create_task(task_func()) loop.call_soon(task_canceller, task) try: await task except asyncio.CancelledError: print(’main() also sees task as canceled’) event_loop = asyncio.get_event_loop()try: event_loop.run_until_complete(main(event_loop))finally: event_loop.close()

結果輸出如下：

creating taskin task_func, sleepingin task_cancellercanceled the tasktask_func was canceledmain() also sees task as canceled

以上這篇在python里創(chuàng)建一個任務(Task)實例就是小編分享給大家的全部內(nèi)容了，希望能給大家一個參考，也希望大家多多支持好吧啦網(wǎng)。