Python进程管理工具可以通过多种方式使用,以下是一些常见的用法示例:
使用os模块创建新的进程:import ospid = os.fork() # 创建一个子进程if pid == 0:# 子进程代码print("This is a child process")else:# 父进程代码print("This is the parent process")使用subprocess模块执行外部命令: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())使用multiprocessing模块创建和管理多个进程:import multiprocessingdef 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() # 等待所有进程完成使用第三方库celery进行分布式任务管理:from celery import Celeryapp = Celery('myapp', broker='pyamqp://guest@localhost//')@app.taskdef add(x, y):return x + yresult = add.delay(4, 6)print(result.get())这只是一些简单的示例,实际使用中可以根据具体需求选择合适的工具和方法来管理和操作进程。