multiprocessing
是 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
并打印出來。接下來,我們創建了 5 個進程,并將 worker
函數作為目標傳遞給它。我們還為每個進程提供了一個不同的參數(0 到 4)。
p.start()
方法用于啟動進程,process.join()
方法用于等待進程完成。最后,我們使用一個 for 循環遍歷進程列表,等待所有進程完成。
這個示例展示了如何使用 multiprocessing
庫創建多個進程并并行執行任務。你可以根據自己的需求修改這個示例,以適應不同的任務和場景。