Python3利用gevent.pool限制协程并发数量的实现方法

小岛来信

发布时间：2026-10-14| 7人浏览过

原创

本文介绍如何在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)

客户端通过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协程并发相关内容，建议查阅本站过往文章或继续阅读后续教程，感谢大家的支持！