Python中怎么實現并發編程

186次閱讀

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

在 Python 中實現并發編程可以使用多種方法，其中最常用的是使用線程和協程。以下是一些常用的并發編程方法：

使用 threading 模塊：可以使用 threading 模塊來創建和管理線程。線程可以并發執行多個任務，從而提高程序的性能。可以使用 threading.Thread 類來創建新的線程，并使用 start() 方法來啟動線程。可以使用 threading.Lock 類來實現線程間的同步。

import threading

def worker():
    print('Hello from worker')

thread = threading.Thread(target=worker)
thread.start()

使用 concurrent.futures 模塊：concurrent.futures 模塊提供了高級的接口來管理并發任務。可以使用 ThreadPoolExecutor 類來創建線程池，并使用 submit() 方法來提交任務。可以使用 ThreadPoolExecutor.map() 方法來并發執行多個任務，并返回結果。

from concurrent.futures import ThreadPoolExecutor

def worker():
    return 'Hello from worker'

with ThreadPoolExecutor() as executor:
    result = executor.submit(worker).result()
    print(result)

使用 asyncio 模塊：asyncio 模塊提供了異步編程的支持，可以使用 async 和 await 關鍵字來定義協程。可以使用 asyncio.run() 函數來運行協程。可以使用 asyncio.create_task() 函數來創建任務，然后使用 await 關鍵字來等待任務完成。

import asyncio

async def worker():
    return 'Hello from worker'

async def main():
    task = asyncio.create_task(worker())
    result = await task
    print(result)

asyncio.run(main())