importasyncioimportfunctoolsimportsignalcounter=0asyncdefrun_bash_sleep():globalcountercounter+=1local_counter=countertry:print(f"Started -{local_counter}")proc=awaitasyncio.create_subprocess_exec('bash','-c','sleep .001',stdout=asyncio.subprocess.PIPE,stderr=asyncio.subprocess.PIPE,start_new_session=True    )print(f"Waiting -{local_counter}")stdout,stderr=awaitproc.communicate()print(f"Done -{local_counter}!")exceptasyncio.CancelledError:print(f"Canceled -{local_counter}!")asyncdefrun_loop(loop):max_jobs=8active_tasks= []whileTrue:try:# Add jobs to the list of active jobswhilelen(active_tasks)<max_jobs:active_tasks.append(loop.create_task(run_bash_sleep()))# All tasks have finished, end the loopiflen(active_tasks)==0:break# Wait for a test to finish (or a 1 second timeout)done,pending=awaitasyncio.wait(active_tasks,timeout=1,return_when=asyncio.FIRST_COMPLETED      )print(f"Running jobs:{len(active_tasks)}")# Update the active jobsactive_tasks=list(pending)exceptasyncio.CancelledError:max_jobs=0defstop_asyncio_loop(signame,loop):fortaskinasyncio.all_tasks(loop):task.cancel()defmain():loop=asyncio.new_event_loop()asyncio.set_event_loop(loop)forsignamein {'SIGINT','SIGTERM'}:loop.add_signal_handler(getattr(signal,signame),functools.partial(stop_asyncio_loop,signame,loop)    )loop.run_until_complete(loop.create_task(run_loop(loop)))main()