在Python中,可以使用multiprocessing
模塊來實現多進程并發代碼。下面是一個簡單的例子:
import multiprocessing
def worker(name):
"""子進程的工作函數"""
print(f'Worker {name} starting...')
# 子進程的具體工作任務
# ...
if __name__ == '__main__':
# 創建并啟動多個子進程
processes = []
for i in range(5):
p = multiprocessing.Process(target=worker, args=(i,))
p.start()
processes.append(p)
# 等待所有子進程結束
for p in processes:
p.join()
print('All workers finished.')
在上述代碼中,首先定義了一個worker
函數,它是子進程的工作函數,用于執行具體的工作任務。然后在主程序中,通過創建多個Process
對象,并指定目標函數和參數來創建并啟動多個子進程。最后通過join
方法等待所有子進程結束。
在實際使用中,可以根據具體的需求來設計并發任務,可以使用進程池、隊列等多種方式來實現多進程并發。需要根據實際場景來選擇最合適的方式。