**客户端示例&说明**
示例代码:
urls = ["
import eventlet
from eventlet.green import urllib2
def fetch(url):
return urllib2.urlopen(url).read()
pool = eventlet.GreenPool()
for body in pool.imap(fetch, urls):
print "got body", len(body)
from eventlet.green import urllib2
引入支持并发yield的urllib2实现
与标准urllib2并无不同,只是使用green socket做通信
pool = eventlet.GreenPoll()
建立一个可容纳>1000的green线程池,提供并发支持
for body in pool.imap(fetch, url)
imap提供循环内的部分并发运行的能力,并且保证执行结果按执行顺序返回
注:
1.这个并发和顺序返回的特性非常重要
2.文档中号称,即使并发量很大,也不会占用太多内存(以GB计)
**服务器端示例&说明**
示例代码
import eventlet
def handle(client):
while True:
c = client.recv(1)
if not c: break
client.sendall(c)
server = eventlet.listen(('0.0.0.0', 6000))
pool = eventlet.GreenPool(10000)
while True:
new_sock, address = server.accept()
pool.spawn_n(handle, new_sock)
pool = eventlet.GreenPool(10000)
建立一个容纳10000个线程的green线程池
pool.spawn_n(handle, new_sock)
因为这里,accept循环并不关心处理结果,所以用了spawn_n(而不是spawn)方法