python 动态添加进程
时间: 2023-06-29 15:06:04 浏览: 143
详解python分布式进程
在 Python 中,可以使用 multiprocessing 模块来创建进程。
动态添加进程需要使用 multiprocessing.Process 类。以下是一个简单的示例代码:
```python
import multiprocessing
import time
def worker():
name = multiprocessing.current_process().name
print(f'{name} starting')
time.sleep(2)
print(f'{name} exiting')
if __name__ == '__main__':
processes = []
for i in range(5):
p = multiprocessing.Process(target=worker, name=f'Process-{i}')
processes.append(p)
p.start()
for p in processes:
p.join()
```
在这个示例中,我们定义了一个 worker 函数,该函数将作为进程的目标函数运行。然后我们使用 for 循环动态地创建了 5 个进程,并将它们添加到一个列表中。最后,我们使用 join() 方法等待所有进程完成。
请注意,如果您的程序在 Windows 上运行,请将进程创建代码放在 `if __name__ == '__main__':` 语句中,以避免 multiprocessing 模块的启动问题。
阅读全文