代码之家 › 专栏 › 技术社区 › Aravind

如何在asyncio python中使用子进程模块限制并发进程的数量

python-asyncio subprocess python

Aravind · 技术社区 · 7 年前

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( )

1 回复 | 直到 7 年前

Ogaga Uzoh 7 年前

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

注意,你应该确保工作数量的增加不会比你实际做的快得多。否则,你将需要比这更复杂的东西。

推荐文章

sudam edirisinghe · python不为循环运行

2 年前

Andrew · 在使用元组/列表的同时使用子进程执行命令?

3 年前

Bjergsen · 子流程。getstatusoutput()引发异常:UnicodeDecodeError

3 年前

Helena · 如何通过Python3将多个带值的参数传递给可执行文件?

3 年前

krock1516 · 如何通过子进程调用python3克服类型错误

3 年前

CN-LanBao · 如何从子进程获取标准输出。带超时检查的Popen优雅吗?

3 年前

416c6578616e646572204d6f72656e · 使用子进程popen运行list命令字符串并获取输出

7 年前

jakun · Python子进程之间的差异。具有shell=True和真实shell的Popen

7 年前

Lone Ronin Jobins John · -regex:没有这样的文件或目录

7 年前

Hayden Seward · |未在子流程中工作。呼叫

7 年前