Python：gevent 库高级用法举例和应用详解

import gevent  # 导入gevent库
from gevent import monkey; monkey.patch_all()  # 打补丁以支持协作式多任务
import requests  # 导入requests库用于发送HTTP请求

# 定义一个请求函数
def fetch(url):
    print(f"Fetching {url}")  # 输出正在请求的URL
    response = requests.get(url)  # 发送GET请求
    print(f"Done fetching {url} with status {response.status_code}")  # 输出请求状态

# URL列表
urls = ['https://www.example.com', 'https://www.python.org', 'https://www.github.com']

# 创建协程
jobs = [gevent.spawn(fetch, url) for url in urls]  # 为每个URL创建一个协程
gevent.joinall(jobs)  # 等待所有协程完成

import gevent  # 导入gevent库
from gevent import sleep  # 导入sleep函数来模拟IO操作

# 定义一个长时间运行的任务
def long_task(identifier):
    print(f"Task {identifier} is starting...")  # 输出任务开始
    sleep(5)  # 模拟一个IO操作，假设需要5秒
    print(f"Task {identifier} is done!")  # 输出任务完成

# 创建协程
tasks = [gevent.spawn(long_task, i) for i in range(3)]  # 创建多个长时间运行的任务
gevent.joinall(tasks)  # 等待所有任务完成

import gevent  # 导入gevent库
from gevent import monkey; monkey.patch_all()  # 打补丁以支持协作式多任务
import asyncio  # 导入asyncio库以支持异步操作
import websockets  # 导入websockets库进行WebSocket通信

# 定义WebSocket处理函数
async def websocket_client(uri):
    async with websockets.connect(uri) as websocket:  # 连接WebSocket服务器
        await websocket.send("Hello, Server!")  # 向服务器发送消息
        response = await websocket.recv()  # 接收来自服务器的消息
        print(f"Received message: {response}")  # 输出接收到的信息

# 创建协程并运行
async def main():
    uri = "ws://localhost:8000"  # WebSocket服务器地址
    gevent.joinall([gevent.spawn(websocket_client, uri)])  # 将WebSocket客户端嵌入协程中

gevent.spawn(main)  # 运行主函数
gevent.wait()  # 等待所有任务完成