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 vote285 views1 answer
How to get table schema sql pyodbc
Python
1 vote201 views2 answers
How can you know if a year is a leap year
Python
5 votes265 views1 answer
Pip3 install pyaml
Python
1 vote194 views1 answer
Load diamonds dataset from sns
Python
0 vote221 views1 answer
Compute Jordan normal form of matrix in Python / NumPy
Python
1 vote216 views1 answer
Python how to make an empty list
Python
58 votes172 views1 answer
Case in pyhton
Python
10 votes200 views2 answers
Convert list to nd array
Python
13 votes221 views3 answers
Pandas set a value in colmns as the maximum value
Python
16 votes222 views2 answers
What is my python working directory
Python