Python子进程集

创建子进程¶

coroutine asyncio.create_subprocess_exec(program, *args, stdin=None, stdout=None, stderr=None, loop=None, limit=None, **kwds)¶

创建一个子进程。

limit 参数为 Process.stdout 和 Process.stderr 设置 StreamReader 包装器的缓冲区上限（如果将 subprocess.PIPE 传给了 stdout 和 stderr 参数）。

返回一个 Process 实例。

有关其他形参的说明请查阅 loop.subprocess_exec() 的文档。

coroutine asyncio.create_subprocess_shell(cmd, stdin=None, stdout=None, stderr=None, loop=None, limit=None, **kwds)¶

运行 cmd shell 命令。

limit 参数为 Process.stdout 和 Process.stderr 设置 StreamReader 包装器的缓冲区上限（如果将 subprocess.PIPE 传给了 stdout 和 stderr 参数）。

返回一个 Process 实例。

有关其他形参的说明请查阅 loop.subprocess_shell() 的文档。

常量¶

asyncio.subprocess.PIPE¶

可以被传递给 stdin, stdout 或 stderr 形参。

如果 PIPE 被传递给 stdin 参数，则 Process.stdin 属性将会指向一个 StreamWriter 实例。

如果 PIPE 被传递给 stdout 或 stderr 参数，则 Process.stdout 和 Process.stderr 属性将会指向 StreamReader 实例。

asyncio.subprocess.STDOUT¶

可以用作 stderr 参数的特殊值，表示标准错误应当被重定向到标准输出。

asyncio.subprocess.DEVNULL¶

可以用作 stdin, stdout 或 stderr 参数来处理创建函数的特殊值。 它表示将为相应的子进程流使用特殊文件 os.devnull。

与子进程交互¶

create_subprocess_exec() 和 create_subprocess_shell() 函数都返回 Process 类的实例。 Process 是一个高层级包装器，它允许与子进程通信并监视其完成情况。

class asyncio.subprocess.Process¶

一个用于包装 create_subprocess_exec() and create_subprocess_shell() 函数创建的 OS 进程的对象。

这个类被设计为具有与 subprocess.Popen 类相似的 API，但两者有一些重要的差异:

• 不同于 Popen，Process 实例没有与 poll() 方法等价的方法；

• communicate() 和 wait() 方法没有 timeout 形参；要使用 wait_for() 函数；

• Process.wait() 方法是异步的，而 subprocess.Popen.wait() 方法则被实现为阻塞型忙循环；

• universal_newlines 形参不被支持。

这个类不是线程安全的（not thread safe）。

请参阅 子进程和线程 部分。

coroutine wait()¶

等待子进程终结。

设置并返回 returncode 属性。

注解

当使用 stdout=PIPE 或 stderr=PIPE 并且子进程产生了足以阻塞 OS 管道缓冲区等待接收更多的数据的输出时，此方法会发生死锁。 当使用管道时请使用 communicate() 方法来避免这种情况。

coroutine communicate(input=None)¶

与进程交互:

1. 发送数据到 stdin (如果 input 不为 None)；

2. 从 stdout 和 stderr 读取数据，直至到达 EOF；

3. 等待进程终结。

可选的 input 参数为将被发送到子进程的数据 (bytes 对象)。

返回一个元组 (stdout_data,stderr_data)。

如果在将 input 写入到 stdin 时引发了 BrokenPipeError 或 ConnectionResetError 异常，异常会被忽略。 此条件会在进程先于所有数据被写入到 stdin 之前退出时发生。

如果想要将数据发送到进程的 stdin，则创建进程时必须使用 stdin=PIPE。 类似地，要在结果元组中获得任何不为 None 的值，则创建进程时必须使用 stdout=PIPE 和/或 stderr=PIPE 参数。

注意，数据读取在内存中是带缓冲的，因此如果数据量过大或不受则不要使用此方法。

send_signal(signal)¶

将信号 signal 发送给子进程。

注解

在 Windows 上，SIGTERM 是 terminate() 的别名。 CTRL_C_EVENT 和 CTRL_BREAK_EVENT 可被发送给创建时附带 creationflags 形参且其中包括 CREATE_NEW_PROCESS_GROUP 的进程。

terminate()¶

停止子进程。

在 POSIX 系统中此方法会发送 signal.SIGTERM 给子进程。

在 Windows 上会调用 Win32 API 函数 TerminateProcess() 以停止子进程。

kill()¶

杀掉子进程。

在 POSIX 系统中此方法会发送 SIGKILL 给子进程。

在 Windows 上此方法是 terminate() 的别名。

stdin¶

标准输入流 (StreamWriter) 或者如果进程创建时设置了``stdin=None`` 则为 None。

stdout¶

标准输出流 (StreamReader) 或者如果进程创建时设置了 stdout=None 则为 None。

stderr¶

标准错误流 (StreamReader) 或者如果进程创建时设置了 stderr=None 则为 None。

警告

使用 communicate() 方法而非 process.stdin.write(), awaitprocess.stdout.read() 或 awaitprocess.stderr.read。 这可以避免由于流暂停读取或写入并阻塞子进程而导致的死锁。

pid¶

进程标识号（PID）。

注意对于由Note that for processes created by the create_subprocess_shell() 函数所创建的进程，这个属性将是所生成的 shell 的 PID。

returncode¶

当进程退出时返回其代号。

None 值表示进程尚未终止。

一个负值 -N 表示子进程被信号 N 中断 (仅 POSIX).

importasyncio
importsys
asyncdefget_date():
code='import datetime; print(datetime.datetime.now())'
# Create the subprocess; redirect the standard output
# into a pipe.
proc=awaitasyncio.create_subprocess_exec(
sys.executable,'-c',code,
stdout=asyncio.subprocess.PIPE)
# Read one line of output.
data=awaitproc.stdout.readline()
line=data.decode('ascii').rstrip()
# Wait for the subprocess exit.
awaitproc.wait()
returnline
ifsys.platform=="win32":
asyncio.set_event_loop_policy(
asyncio.WindowsProactorEventLoopPolicy())
date=asyncio.run(get_date())
print(f"Current date: {date}")