python3通过gevent.pool限制协程并发数量的实现方法

#!/usr/bin/env python
# -*- coding: utf-8 -*-
# @Author  : Cain
# @Email: 771535427@qq.com
# @Filename: gevnt_sockserver.py
# @Last modified : 2017-11-24  16:31
# @Description:
import sys
import socket
import time
import gevent
from gevent import socket,monkey,pool #导入pool
monkey.patch_all()
def server(port, pool):
 s = socket.socket()
 s.bind(('0.0.0.0', port))
 s.listen()
 while True:
  cli, addr = s.accept()
  #print("Welcome %s to SocketServer" % str(addr[0]))
  pool.spawn(handle_request, cli) #通过pool.spawn()运行协程
def handle_request(conn):
 try:
  data = conn.recv(1024)
  print("recv:", data)
  data = 'From SockeServer:192.168.88.118---%s' % data.decode("utf8")
  conn.sendall(bytes(data, encoding="utf8"))
  if not data:
conn.shutdown(socket.SHUT_WR)
 except Exception as ex:
  print(ex)
 finally:
  conn.close()
if __name__ == '__main__':
 pool = pool.Pool(5) #限制并发协程数量5
 server(8888, pool)

import socket
import gevent
from gevent import socket, monkey
from gevent.pool import Pool
import time
monkey.patch_all()
HOST = '192.168.88.118'
PORT = 8888
def sockclient(i):
 #time.sleep(2)
 s = socket.socket()
 s.connect((HOST, PORT))
 #print(gevent.getcurrent())
 msg = bytes(("This is gevent: %s" % i),encoding="utf8")
 s.sendall(msg)
 data = s.recv(1024)
 print("Received", data.decode())
 s.close()
pool = Pool(5)
threads = [pool.spawn(sockclient, i) for i in range(2000)]
gevent.joinall(threads)