Python的进程及进程池详解
在Python中,进程是一种执行计算机程序的方式。它们是操作系统分配资源的基单位。本文将为您提供一个完整攻略,详细讲解Python的进程进程池,包括进程的创建启动停止、等待和进程池的使用,并提供两个示例说明。
1. 进的创建、启动、停止和等待
在Python中可以使用multiprocessing
模块创建和管理进程。以下是一个使用multiprocessing
模块创建、启动、停止和等待进程的示例:
import multiprocessing
import time
def worker():
print("Worker started")
time.sleep(2)
print("Worker finished")
if __name__ == '__main__':
process = multiprocessing.Process(target=worker)
print("Process created")
process.start()
print("Process started")
process.join()
print("Process finished")
在上面的示例中,我们定义了一个名为worker
的函数,它将在进程中执行。在main
函数中,我们使用multiprocessing.Process
类创建了一个进程,并将worker
函数作为目标。在启动进程之前,我们输出了一条消息表示进程已创建。在启动进程之后,我们输出了一条消息表示进程已启动。在等待进程完成之后,我们输出了一条消息表示进程已完成。
2. 进程池的使用
在Python中,可以使用multiprocessing.Pool
类创建进程池。进程池是一组可重用的进程,它们可以在需要时执行任务。以下是一个使用multiprocessing.Pool
类创建进程池的示例:
import multiprocessing
import time
def worker(num):
print("Worker %d started" % num)
time.sleep(2)
print("Worker %d finished" % num)
if __name__ == '__main__':
pool = multiprocessing.Pool(processes=2)
print("Pool created")
for i in range(4):
pool.apply_async(worker, args=(i,))
print("Jobs submitted")
pool.close()
pool.join()
print("Jobs completed")
在上面的示例中,我们定义了一个名为worker
的函数,它将在进程池中执行。在main
函数中,我们使用multiprocessing.Pool
类创建了一个进程池,并将进程数设置为2。后,我们使用apply_async
方法向进程池中提交了4个任务。在提交任务之后,我们输出了一条消息表示任务已提交。在等待所有任务完成之后,我们输出了一条消息表示任务已完成。
3. 示例二
以下是另一个使用multiprocessing
类创建进程池的示例:
import multiprocessing
import time
def worker(num):
print("Worker %d started" % num)
time.sleep(2)
print("Worker %d finished" % num)
if __name__ == '__main__':
pool = multiprocessing.Pool(processes=2)
print("Pool created")
results = []
for i in range(4):
result = pool.apply_async(worker, args=(i,))
results.append(result)
print("Jobs submitted")
for result in results:
result.wait()
print("Jobs completed")
在上面的示例中,我们使用apply_async
方法向进程池中提交了4个任务,并将结果存储在一个列表中。在提交任务之后,我们输出了一条消息表示任务已提交。然后,我们使用wait
方法等待所有任务完成。在等待所有任务完成之后,我们输出了一条消息表示任务已完成。
总结
在Python中,可以使用multiprocessing
模块创建和管理进程,以及使用multiprocessing.Pool
类创建进程池。本文详细讲解了Python的进程及进程池,包括进程的创建、动、停止、等待和进程池的使用,并提供了两个示例说明,分别使用multiprocessing
模块创建、启动、停止和等待进程,以及使用multiprocessing.Pool
类创建进程池。
本站文章如无特殊说明,均为本站原创,如若转载,请注明出处:Python的进程及进程池详解 - Python技术站