import asyncio
import asyncio.subprocess
args="blah blah argument "
create=asyncio.create_subprocess_shell(args,stdout=asyncio.subprocess.PIPE)
proc = await create
output= await proc.stdout.read( )
这是我的服务器代码的一部分,它从客户端获得1000次并行命中。现在我应该如何限制服务器创建的最大子进程数以运行参数blah blah。因为这是代码使用100%的我的CPU。我需要在smae cpu上部署其他服务器
asyncio.Semaphore是限制同时工作的内部反击的一种方式:
sem = asyncio.Semaphore(10)
async def do_job(args):
async with sem: # Don't run more than 10 simultaneous jobs below
proc = await asyncio.create_subprocess_shell(args, stdout=PIPE)
output = await proc.stdout.read()
return output
请注意,您应该确保工作数量的增加速度不会比您实际完成的速度快得多。否则,你需要一些比这更复杂的东西。