Python中怎么实现并发编程

26次阅读

共计 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())