from multiprocessing import Process def f(name): print('hello', name) if __name__ == '__main__': p = Process(target=f, args=('bob',)) p.start() p.join()
时间: 2023-11-20 15:07:19 浏览: 103
这是一个使用 Python 的 multiprocessing 模块创建进程的代码示例。在这个例子中,首先定义了一个函数 f,它接受一个参数 name,打印出 "hello" 和 name。然后,在主程序中创建了一个 Process 对象 p,它的 target 参数指定为函数 f,args 参数为一个元组 ('bob',)。接着,通过调用 p.start() 方法启动进程,然后调用 p.join() 方法等待该进程结束。在进程执行过程中,会输出 "hello bob"。
相关问题
import multiprocessing as mp def foo(q): q.put('hello') if __name__ == '__main__': mp.set_start_method('spawn') q = mp.Queue() p = mp.Process(target=foo, args=(q,)) p.start() print(q.get()) p.join()
这段代码是一个使用 multiprocessing 模块实现的进程间通信的例子。它创建了一个进程 p,将一个 Queue 对象 q 作为参数传递给进程 p。进程 p 执行函数 foo,将字符串 'hello' 放入 Queue 对象 q 中。主进程通过调用 q.get() 从 Queue 对象 q 中取出了 'hello' 字符串并打印,最后通过 p.join() 等待进程 p 结束。该进程间通信方式是使用 Queue 对象实现的,由于 Queue 对象是线程安全的,因此可以在多个进程中安全地使用。这里使用了 spawn 的启动方式,因为它比 fork 更适合在 Windows 平台上使用。
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() 获取子进程的参数并打印
在这个代码中,我们可以使用 `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
```
其中,每行打印的是一个子进程中传递的参数。
阅读全文