python并行調用多個服務怎么實現

133次閱讀

共計 956 個字符，預計需要花費 3 分鐘才能閱讀完成。

在 Python 中，可以使用多種方法來實現并行調用多個服務，這里介紹兩種常見的方法。

使用 multiprocessing 模塊：multiprocessing是 Python 提供的一個用于實現并行計算的模塊，可以通過創建多個進程來同時執行多個任務?？梢允褂?Process 類來創建進程，并使用 start() 方法啟動進程。下面是一個示例代碼：

from multiprocessing import Process

def service1():
    # 實現服務 1 的代碼

def service2():
    # 實現服務 2 的代碼

if __name__ == '__main__':
    p1 = Process(target=service1)
    p2 = Process(target=service2)
    p1.start()
    p2.start()
    p1.join()
    p2.join()

在上面的示例中，我們創建了兩個進程 p1 和p2，分別調用 service1 和service2函數。然后使用 start() 方法啟動進程，并使用 join() 方法等待進程結束。

使用 concurrent.futures 模塊：concurrent.futures是 Python 3 中的一個內置模塊，用于高級并發編程。它提供了一個 ThreadPoolExecutor 類，可以用來創建線程池并并行執行多個任務。下面是一個示例代碼：

from concurrent.futures import ThreadPoolExecutor

def service1():
    # 實現服務 1 的代碼

def service2():
    # 實現服務 2 的代碼

if __name__ == '__main__':
    with ThreadPoolExecutor() as executor:
        future1 = executor.submit(service1)
        future2 = executor.submit(service2)