V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
推荐学习书目
Learn Python the Hard Way
Python Sites
PyPI - Python Package Index
http://diveintopython.org/toc/index.html
Pocoo
值得关注的项目
PyPy
Celery
Jinja2
Read the Docs
gevent
pyenv
virtualenv
Stackless Python
Beautiful Soup
结巴中文分词
Green Unicorn
Sentry
Shovel
Pyflakes
pytest
Python 编程
pep8 Checker
Styles
PEP 8
Google Python Style Guide
Code Style from The Hitchhiker's Guide
chen222246lei
V2EX  ›  Python

为什么服务端设置 gevent.pool.Pool()池的数量不起作用?

  •  
  •   chen222246lei · 2018-12-18 09:46:53 +08:00 · 999 次点击
    这是一个创建于 2172 天前的主题,其中的信息可能已经有所发展或是发生改变。
    --server 端
    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:---%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(2) #限制并发协程数量 5
    server(8888, pool)

    --client 端
    import socket
    import gevent
    from gevent import socket, monkey
    from gevent.pool import Pool
    import time

    monkey.patch_all()

    HOST = '192.168.2.202'
    PORT = 8888
    def sockclient(i):
    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(50)
    threads = [pool.spawn(sockclient, i) for i in range(2000)]
    gevent.joinall(threads)

    按道理说我在服务端设置协程池的数量为 2, 而客户端一次性向服务端发 50 个,服务端应该报错才对, 可是服务端并没有报错, 而且即使我开 3 个客户端同时连接服务端程序依然运行正常, 这是怎么原因? 服务端的 pool.Pool(2)完全没有作用呀.
    chen222246lei
        1
    chen222246lei  
    OP
       2018-12-20 09:23:22 +08:00
    哪位大佬帮忙看看是怎么回事? 我不信没人懂.
    关于   ·   帮助文档   ·   博客   ·   API   ·   FAQ   ·   实用小工具   ·   3453 人在线   最高记录 6679   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 22ms · UTC 11:02 · PVG 19:02 · LAX 03:02 · JFK 06:02
    Developed with CodeLauncher
    ♥ Do have faith in what you're doing.