在Python中,可以使用multiprocessing
库来创建和控制多个进程。这个库提供了Process
类,可以用来创建和管理进程。以下是一些关于如何使用multiprocessing
库进行并发编程的基本示例:
- 导入
multiprocessing
库:
import multiprocessing
- 创建一个函数,该函数将在多个进程中执行:
def worker(num): print(f"Worker: {num}")
- 创建一个
Process
对象,将目标函数作为参数传递,并启动进程:
process = multiprocessing.Process(target=worker, args=(5,)) process.start()
- 等待进程完成:
process.join()
- 创建多个进程并等待它们全部完成:
processes = [] for i in range(5): p = multiprocessing.Process(target=worker, args=(i,)) processes.append(p) p.start() for process in processes: process.join()
- 使用
multiprocessing.Pool
来并行执行一组任务。例如,以下代码将worker
函数应用于0到9的整数列表,并将结果存储在一个字典中:
from multiprocessing import Pool def worker(num): return num * num if __name__ == "__main__": with Pool(processes=4) as pool: results = pool.map(worker, range(10)) print(results)
这些示例展示了如何在Python中使用multiprocessing
库创建和控制多个进程。你可以根据自己的需求调整这些示例,以实现更复杂的并发任务。