Python协程如何用gevent实现？

Python的gevent通过轻量级协程（greenlet）和关键的monkey patching机制，将标准库中的阻塞IO操作无缝转为非阻塞，让开发者以近乎同步的简洁代码风格实现高并发——只需`monkey.patch_all()`打补丁、`gevent.spawn()`启动协程、`gevent.joinall()`等待完成，再配合`Pool`灵活控并发，即可在爬虫、API批量调用等IO密集型场景中大幅提升响应效率，真正兼顾性能与可读性。

Python中的gevent模块是一个基于协程的并发库，它使用greenlet（轻量级协程）实现异步编程，通过monkey patching将标准库中的阻塞操作变为非阻塞，从而实现高效的并发处理。下面介绍如何使用gevent进行常见操作。

安装与基础用法

首先需要安装gevent：

最简单的gevent程序如下：

import gevent
from gevent import monkey

# 打补丁，让标准库中的阻塞操作变成非阻塞
monkey.patch_all()

def task(name, duration):
    print(f"Task {name} starting")
    gevent.sleep(duration) # 模拟IO等待
    print(f"Task {name} finished")

# 创建多个协程任务
jobs = [
    gevent.spawn(task, "A", 2),
    gevent.spawn(task, "B", 1),
] 

# 等待所有任务完成
gevent.joinall(jobs)

Monkey Patching 的作用

gevent的核心是monkey patching。Python的标准库如socket、time、threading等默认是阻塞的，gevent通过monkey.patch_all()替换这些模块中的阻塞函数为协作式版本。

例如：

from gevent import monkey
monkey.patch_socket() # 只打补丁socket
# 或者更常用：
monkey.patch_all()

注意：必须在导入其他模块之前调用patch，否则无效。通常放在文件最开始。

实际应用：并发请求网络资源

使用gevent可以轻松实现高并发HTTP请求：

import gevent
from gevent import monkey
monkey.patch_all() # 打补丁，支持requests等库

import requests

def fetch(url):
    print(f"Fetching {url}")
    response = requests.get(url)
    print(f"{url} -> {response.status_code}")

urls = [
    "https://httpbin.org/delay/1",
    "https://httpbin.org/delay/2",
    "https://httpbin.org/get"
]

# 并发执行
gevent.joinall([gevent.spawn(fetch, url) for url in urls])

原本串行需要几秒的操作，现在几乎同时发起，总耗时由最长的那个决定。

控制并发数量：使用Pool

当任务过多时，可以用gevent.pool.Pool限制并发数：

from gevent.pool import Pool

def worker(url):
    response = requests.get(url)
    return f"{url}: {response.status_code}"

pool = Pool(5) # 最多5个并发
results = pool.map(worker, urls)

for result in results:
    print(result)

Pool也支持异步方式：pool.spawn() + gevent.joinall()。

基本上就这些。gevent的优势在于写法接近同步代码，逻辑清晰，适合IO密集型任务，比如爬虫、API调用、长轮询服务等。掌握patch机制和spawn/joinall模式，就能高效利用gevent实现并发。

以上就是本文的全部内容了，是否有顺利帮助你解决问题？若是能给你带来学习上的帮助，请大家多多支持golang学习网！更多关于文章的相关知识，也可关注golang学习网公众号。