用Python写一个并行的代码
时间: 2024-04-25 14:05:11 浏览: 17
好的,下面是一个简单的 Python 并行代码示例,使用了 `multiprocessing` 模块:
```python
import multiprocessing
def worker(num):
"""单个进程的工作函数"""
print('Worker %d started' % num)
return
if __name__ == '__main__':
# 创建进程池,最大进程数为 4
pool = multiprocessing.Pool(processes=4)
# 创建 8 个任务,将它们分配给进程池中的进程
for i in range(8):
pool.apply_async(worker, args=(i,))
# 关闭进程池并等待所有进程完成
pool.close()
pool.join()
print('All workers completed')
```
以上代码中,我们先定义了一个 `worker` 函数,它接受一个数字参数 `num`,表示这个进程的编号。在这个函数中,我们只是简单地打印出进程的编号。
然后,在 `if __name__ == '__main__':` 中,我们创建了一个进程池,将最大进程数设置为 4。接着,我们创建了 8 个任务,并将它们分配给进程池中的进程。最后,我们关闭进程池并等待所有进程完成。
这个代码示例中,使用了 `apply_async` 方法来将任务分配给进程池。这个方法是异步的,即它会立即返回,而不会等待任务完成。如果需要等待任务完成并获得结果,可以使用 `apply` 方法。