在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
库创建和控制多个进程。你可以根据自己的需求调整这些示例,以实现更复杂的并发任务。