Patch loop runner _run_once

import asyncio
def _run_once(self):
	num_tasks = len(self._scheduled)
    print("num tasks in queue: {}".format(num_tasks))
    super(asyncio.SelectorEventLoop, self)._run_once()

EventLoop = asyncio.SelectorEventLoop
EventLoop._run_once = _run_once
loop = EventLoop()
asyncio.set_event_loop(loop)
async def task(n):
    await asyncio.sleep(n)
    print("sleep: {} sec".format(n))

coro = loop.create_task(task(3))
loop.run_until_complete(coro)
# num tasks in queue: 0
# num tasks in queue: 1
# num tasks in queue: 0
# sleep: 3 sec
# num tasks in queue: 0
loop.close()

Source: pythonsheets.com

Similar codes

0 vote320 views1 answer
How to apply labelencoder on multiple columns at once
Python
11 votes369 views3 answers
How to get a specific character in a string on number python
Python
0 vote373 views1 answer
How to make it so we can give unlimited parameters in python function
Python
0 vote331 views1 answer
Python dict keys to string
Python
1 vote359 views1 answer
How to retrieve dictionary values in python by index
Python
0 vote345 views2 answers
Reverse column order pandas
Python
0 vote295 views1 answer
Cx_freeze include images in specific path
Python
0 vote350 views1 answer
Convert from R to python
Python
15 votes312 views3 answers
Get max value column pandas
Python
0 vote316 views1 answer
Python division no remainder
Python