1 import gevent
 2 def fun1():
 3     print('输出函数1')
 4     gevent.sleep(2)
 5     print('函数1结束')
 6 def fun2():
 7     print('输出函数2')
 8     gevent.sleep(1)
 9     print('函数2结束')
10 def fun3():
11     print('输出函数3')
12     gevent.sleep(0)
13     print('函数3结束')
14 gevent.joinall([gevent.spawn(fun1),gevent.spawn(fun2),gevent.spawn(fun3)])生成3个函数的自动切换

import gevent,time
from gevent import monkey
from urllib import request
monkey.patch_all() # gevent补丁，把当前的所有的IO操作都单独的坐上标记def web(url):print('开始爬网页%s' % url)res = request.urlopen(url)data = res.read()print('%d bytes received from %s' % (len(data),url))
urls = ['https://web1/','https://web2/','https://web3/'
]
# 串行模式执行
time_start = time.time()
for url in urls:web(url)
print('同步cost',time.time()-time_start)
# 协程并发模式执行
async_time_start = time.time()
gevent.joinall([gevent.spawn(web,'https://web1/'),gevent.spawn(web,'https://web2/'),gevent.spawn(web,'https://web3/')
])
print('异步cost',time.time()-async_time_start)

 1 import sys,socket,time,gevent
 2 from gevent import socket,monkey
 3 monkey.patch_all()
 4
 5 def server():
 6     s = socket.socket()
 7     s.bind(('0.0.0.0',9999))
 8     s.listen(500)
 9     while True:
10         cli,addr = s.accept()
11        # 主要这里，将每个连进来的客户端对象交给协程并发处理
12         gevent.spawn(handle_request,cli)
13
14 def handle_request(client):
15     while True:
16         try:
17             data = client.recv(1024).decode()
18             print(data)
19             client.send(data.encode('utf-8'))
20             if not data:
21                 client.shutdown(socket.SHUT_WR)
22         except Exception as e:
23             print('err',e)
24         finally:
25             client.close()