python multiprocessing样例
时间: 2023-10-13 09:26:52 浏览: 85
Python多进程示例multiprocess.py
下面是一个简单的Python multiprocessing示例,其中我们使用了`Process`类来创建子进程,并使用`Queue`类来在父进程和子进程之间传递数据:
```python
import multiprocessing
def worker(queue):
"""子进程函数"""
print("子进程开始执行")
data = queue.get() # 从队列中获取数据
print(f"子进程接收到的数据为:{data}")
queue.put("hello from child") # 向队列中加入数据
if __name__ == "__main__":
print("父进程开始执行")
queue = multiprocessing.Queue() # 创建队列对象
process = multiprocessing.Process(target=worker, args=(queue,)) # 创建子进程对象
process.start() # 启动子进程
queue.put("hello from parent") # 向队列中加入数据
data = queue.get() # 从队列中获取数据
print(f"父进程接收到的数据为:{data}")
process.join() # 等待子进程结束
```
在上面的示例中,我们首先创建了一个`Queue`对象,然后使用`Process`类创建了一个子进程。子进程函数`worker`从队列中获取数据,打印出来,并向队列中加入一条数据。主进程先向队列中加入一条数据,然后从队列中获取数据并打印出来。最后,我们使用`join`方法等待子进程结束。
阅读全文