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 vote105 views1 answer
Django include all columns admin show
Python
49 votes135 views2 answers
Add new element to python dictionary
Python
1 vote194 views1 answer
How to set "Unnamed: 0" column as the index in a DataFrame
Python
0 vote172 views1 answer
NameError: name 'after_this_request' is not defined
Python
6 votes158 views5 answers
Python while True
Python
1 vote166 views1 answer
How to add a fuction in python
Python
0 vote151 views1 answer
Send command civil3D
Python
-1 vote161 views1 answer
Sum of diagonal numpy
Python
-3 votes162 views2 answers
Multiplication table python
Python
0 vote154 views1 answer
How to make a column a factor in pandas
Python