Python异步执行CMD命令的具体实现

import subprocess

# 同步执行CMD命令
result = subprocess.run(['dir'], capture_output=True, text=True, shell=True)
print(result.stdout)

import asyncio
import subprocess

async def run_cmd(cmd):
    proc = await asyncio.create_subprocess_shell(
        cmd,
        stdout=asyncio.subprocess.PIPE,
        stderr=asyncio.subprocess.PIPE
    )
    stdout, stderr = await proc.communicate()
    print(f'[{cmd!r} exited with {proc.returncode}]')
    if stdout:
        print(f'[stdout]\n{stdout.decode()}')
    if stderr:
        print(f'[stderr]\n{stderr.decode()}')

# 异步执行多个CMD命令
async def main():
    await asyncio.gather(
        run_cmd('dir'),
        run_cmd('ipconfig'),
        run_cmd('ping localhost')
    )

asyncio.run(main())

import concurrent.futures
import subprocess

def run_cmd(cmd):
    result = subprocess.run(cmd, capture_output=True, text=True, shell=True)
    print(result.stdout)

# 使用ThreadPoolExecutor异步执行CMD命令
with concurrent.futures.ThreadPoolExecutor() as executor:
    future1 = executor.submit(run_cmd, ['dir'])
    future2 = executor.submit(run_cmd, ['ipconfig'])
    future3 = executor.submit(run_cmd, ['ping localhost'])

    # 等待所有命令执行完成
    concurrent.futures.wait([future1, future2, future3])

import asyncio
import os

async def run_cmd(cmd):
    process = await asyncio.create_subprocess_shell(
        cmd,
        stdout=asyncio.subprocess.PIPE,
        stderr=asyncio.subprocess.PIPE
    )
    stdout, stderr = await process.communicate()
    print(f'[{cmd!r} exited with {process.returncode}]')
    if stdout:
        print(f'[stdout]\n{stdout.decode()}')
    if stderr:
        print(f'[stderr]\n{stderr.decode()}')

# 异步执行多个CMD命令
async def main():
    await asyncio.gather(
        run_cmd('dir'),
        run_cmd('ipconfig'),
        run_cmd('ping localhost')
    )

asyncio.run(main())