python3通過gevent.pool限制協(xié)程并發(fā)數(shù)量的實現(xiàn)方法
協(xié)程雖然是輕量級的線程，但到達一定數(shù)量后，仍然會造成服務(wù)器崩潰出錯。最好的方法通過限制協(xié)程并發(fā)數(shù)量來解決此類問題。
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()運行協(xié)程
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) #限制并發(fā)協(xié)程數(shù)量5
server(8888, pool)
client(通過gevent模擬并發(fā)數(shù)量)：
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)
由于服務(wù)器限制連接并發(fā)數(shù)量；所以客戶端同時并發(fā)連接數(shù)超過服務(wù)器端并發(fā)數(shù)量，就會引發(fā)連接錯誤信息：
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] 遠程主機強迫關(guān)閉了一個現(xiàn)有的連接。
到此這篇關(guān)于python3通過gevent.pool限制協(xié)程并發(fā)數(shù)量的文章就介紹到這了,更多相關(guān)python3協(xié)程并發(fā)數(shù)量內(nèi)容請搜索本站以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持本站！
版權(quán)聲明：本站文章來源標注為YINGSOO的內(nèi)容版權(quán)均為本站所有，歡迎引用、轉(zhuǎn)載，請保持原文完整并注明來源及原文鏈接。禁止復制或仿造本網(wǎng)站，禁止在非maisonbaluchon.cn所屬的服務(wù)器上建立鏡像，否則將依法追究法律責任。本站部分內(nèi)容來源于網(wǎng)友推薦、互聯(lián)網(wǎng)收集整理而來，僅供學習參考，不代表本站立場，如有內(nèi)容涉嫌侵權(quán)，請聯(lián)系alex-e#qq.com處理。
關(guān)注官方微信