在Python中,可以使用multiprocessing
模塊來實現多進程。這個模塊提供了Process
類,可以用來創建和管理多個進程。下面是一個簡單的示例:
import multiprocessing
def worker(num):
"""模擬一個需要并行處理的任務"""
print(f"Worker: {num}")
if __name__ == "__main__":
# 創建進程列表
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
模塊。然后,我們定義了一個名為worker
的函數,該函數接受一個參數num
并打印出來。在__main__
部分,我們創建了5個進程,每個進程都運行worker
函數,只是傳入的參數不同。我們使用multiprocessing.Process
類來創建進程,并將其添加到processes
列表中。然后,我們使用p.start()
啟動每個進程,最后使用process.join()
等待所有進程完成。