Python プロセス管理ツールの使い方
Pythonプロセス管理ツールはさまざまな方法で使用できます。以下に一般的な使用例の例をいくつか示します。
- 「これが正解だよ」
import os
pid = os.fork() # 创建一个子进程
if pid == 0:
# 子进程代码
print("This is a child process")
else:
# 父进程代码
print("This is the parent process")
- サブプロセス
import subprocess
# 执行命令并等待命令完成
result = subprocess.run(["ls", "-l"], capture_output=True, text=True)
print(result.stdout)
# 启动一个长时间运行的进程并与其交互
process = subprocess.Popen(["python3", "my_script.py"], stdin=subprocess.PIPE, stdout=subprocess.PIPE)
output, error = process.communicate(input="input data")
print(output.decode())
- マルチプロセッシング
import multiprocessing
def worker(num):
print(f"Worker {num} started")
if __name__ == "__main__":
processes = []
for i in range(5):
p = multiprocessing.Process(target=worker, args=(i,))
p.start()
processes.append(p)
for p in processes:
p.join() # 等待所有进程完成
- セロリー
from celery import Celery
app = Celery('myapp', broker='pyamqp://guest@localhost//')
@app.task
def add(x, y):
return x + y
result = add.delay(4, 6)
print(result.get())
具体的なニーズに応じて適切なツールや手法を選択し、プロセスを管理、操作できる。