def main(): jiaoben=index.zhuxunhuanlei() jinchengs=[] for xu in range(len(xuhao)): jincheng=multiprocessing.Process(target=jiaoben.zhuxunhuan,args=(xuhao[xu],)) jinchengs.append(jincheng) jincheng.start() for jincheng in jinchengs: jincheng.join() if __name__ == '__main__': multiprocessing.freeze_support() main() 获取子进程的参数并打印
时间: 2024-01-27 15:02:36 浏览: 71
在这个代码中,我们可以使用 `multiprocessing.Queue()` 来实现子进程和父进程之间的通信。
以下是一个修改后的例子:
```python
import multiprocessing
def zhuxunhuan(xuhao, queue):
# 子进程中获取参数并打印
data = "Hello from process {}".format(xuhao)
queue.put(data)
def main():
jiaoben = index.zhuxunhuanlei()
xuhao = [1, 2, 3, 4, 5]
queues = []
for xu in range(len(xuhao)):
queue = multiprocessing.Queue()
jincheng = multiprocessing.Process(target=jiaoben.zhuxunhuan, args=(xuhao[xu], queue))
queues.append(queue)
jincheng.start()
for queue in queues:
data = queue.get()
print(data)
for jincheng in jinchengs:
jincheng.join()
if __name__ == '__main__':
multiprocessing.freeze_support()
main()
```
在上述代码中,我们首先创建了一个队列 `queue = multiprocessing.Queue()`,然后将它传递给子进程 `jincheng = multiprocessing.Process(target=jiaoben.zhuxunhuan, args=(xuhao[xu], queue))`。在子进程中,我们使用 `queue.put(data)` 将参数放入队列中。在父进程中,我们遍历所有队列,使用 `queue.get()` 获取队列中的参数并打印。
输出结果为:
```
Hello from process 1
Hello from process 2
Hello from process 3
Hello from process 4
Hello from process 5
```
其中,每行打印的是一个子进程中传递的参数。
阅读全文