在Python中,可以使用multiprocessing
模塊來實(shí)現(xiàn)多進(jìn)程。這個(gè)模塊提供了Process
類,可以用來創(chuàng)建和管理多個(gè)進(jìn)程。下面是一個(gè)簡(jiǎn)單的示例:
import multiprocessing
def worker(num):
"""模擬一個(gè)需要并行處理的任務(wù)"""
print(f"Worker: {num}")
if __name__ == "__main__":
# 創(chuàng)建進(jìn)程列表
processes = []
# 為每個(gè)數(shù)字創(chuàng)建一個(gè)新的進(jìn)程
for i in range(5):
p = multiprocessing.Process(target=worker, args=(i,))
processes.append(p)
p.start()
# 等待所有進(jìn)程完成
for process in processes:
process.join()
在這個(gè)示例中,我們首先導(dǎo)入了multiprocessing
模塊。然后,我們定義了一個(gè)名為worker
的函數(shù),該函數(shù)接受一個(gè)參數(shù)num
并打印出來。在__main__
部分,我們創(chuàng)建了5個(gè)進(jìn)程,每個(gè)進(jìn)程都運(yùn)行worker
函數(shù),只是傳入的參數(shù)不同。我們使用multiprocessing.Process
類來創(chuàng)建進(jìn)程,并將其添加到processes
列表中。然后,我們使用p.start()
啟動(dòng)每個(gè)進(jìn)程,最后使用process.join()
等待所有進(jìn)程完成。