daniil-berg/asyncio-taskpool
1
0
Fork 0
generated from daniil-berg/boilerplate-py
Code Issues Pull Requests Projects Releases 31 Wiki Activity

more precise comments

Browse Source
This commit is contained in:
Daniil Fajnberg 2022-02-08 16:24:37 +01:00
parent 410e73e68b
commit 36d026f433
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
usage/USAGE.md
View File

@ -126,9 +126,8 @@ async def main() -> None:
# The second one will start (with ID 3), only once there is room in the pool, # The second one will start (with ID 3), only once there is room in the pool,
# which -- in this example -- will be the case after ID 2 ends; # which -- in this example -- will be the case after ID 2 ends;
# until then the `starmap` method call **will block**! # until then the `starmap` method call **will block**!
# Once there is room in the pool again, the third one will start immediately (and receive ID 4). # Once there is room in the pool again, the third and fourth will each start (with IDs 4 and 5)
# The last one will start (with ID 5) **only** once there is room in the pool **and** no more than one of these # **only** once there is room in the pool **and** no more than one of these last four tasks is running.
# last four tasks is running.
args_list = [(0, 10), (10, 20), (20, 30), (30, 40)] args_list = [(0, 10), (10, 20), (20, 30), (30, 40)]
print("Calling `starmap`...") print("Calling `starmap`...")
await pool.starmap(other_work, args_list, num_tasks=2) await pool.starmap(other_work, args_list, num_tasks=2)