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

协程虽然是轻量级的线程，但到达一定数量后，仍然会造成服务器崩溃出错。最好的方法通过限制协程并发数量来解决此类问题。

server代码：

#!/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)

client(通过gevent模拟并发数量)：

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)

由于服务器限制连接并发数量；所以客户端同时并发连接数超过服务器端并发数量，就会引发连接错误信息：

Exception in thread Thread-849:
Traceback (most recent call last):
File "C:\Users\admin\AppData\Local\Programs\Python\Python36\lib\threading.py", line 916, in _bootstrap_inner
self.run()
File "C:\Users\admin\AppData\Local\Programs\Python\Python36\lib\threading.py", line 864, in run
self._target(*self._args, **self._kwargs)
File "E:/chengd/python/python3/matp/die/geven_sockclient.py", line 26, in sockclient
data = s.recv(1024)
ConnectionResetError: [WinError 10054] 远程主机强迫关闭了一个现有的连接。

关于python3通过gevent.pool限制协程并发数量的文章就介绍至此，更多相关python3协程并发数量内容请搜索编程宝库以前的文章，希望大家多多支持编程宝库！

简单用py写了一个贪吃蛇游戏，有单人、双人模式，比较简单，适合初学者练手。本上每行重要的语句都有注释，做了什么事一目了然这里介绍双人模式单人模式戳这里：Python简易贪吃蛇小游戏（单人模式）一、游 ...