在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
庫創建和控制多個進程。你可以根據自己的需求調整這些示例,以實現更復雜的并發任務。