主頁 > 知識庫 > python3通過gevent.pool限制協(xié)程并發(fā)數(shù)量的實現(xiàn)方法

python3通過gevent.pool限制協(xié)程并發(fā)數(shù)量的實現(xiàn)方法

熱門標簽:鶴壁手機自動外呼系統(tǒng)違法嗎 銀川電話機器人電話 高德地圖標注收入咋樣 怎么辦理400客服電話 地圖標注多個 萊蕪電信外呼系統(tǒng) 企業(yè)微信地圖標注 B52系統(tǒng)電梯外呼顯示E7 沈陽防封電銷電話卡

協(xié)程雖然是輕量級的線程,但到達一定數(shù)量后,仍然會造成服務器崩潰出錯。最好的方法通過限制協(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)

由于服務器限制連接并發(fā)數(shù)量;所以客戶端同時并發(fā)連接數(shù)超過服務器端并發(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)文章希望大家以后多多支持腳本之家!

您可能感興趣的文章:
  • Python gevent協(xié)程切換實現(xiàn)詳解
  • python 協(xié)程 gevent原理與用法分析
  • Python協(xié)程操作之gevent(yield阻塞,greenlet),協(xié)程實現(xiàn)多任務(有規(guī)律的交替協(xié)作執(zhí)行)用法詳解
  • 簡單了解python gevent 協(xié)程使用及作用
  • 詳解python之協(xié)程gevent模塊

標簽:呼倫貝爾 呼倫貝爾 銀川 三亞 安慶 烏魯木齊 湘西 葫蘆島

巨人網(wǎng)絡通訊聲明:本文標題《python3通過gevent.pool限制協(xié)程并發(fā)數(shù)量的實現(xiàn)方法》,本文關(guān)鍵詞  python3,通過,gevent.pool,限制,;如發(fā)現(xiàn)本文內(nèi)容存在版權(quán)問題,煩請?zhí)峁┫嚓P(guān)信息告之我們,我們將及時溝通與處理。本站內(nèi)容系統(tǒng)采集于網(wǎng)絡,涉及言論、版權(quán)與本站無關(guān)。
  • 相關(guān)文章
  • 下面列出與本文章《python3通過gevent.pool限制協(xié)程并發(fā)數(shù)量的實現(xiàn)方法》相關(guān)的同類信息!
  • 本頁收集關(guān)于python3通過gevent.pool限制協(xié)程并發(fā)數(shù)量的實現(xiàn)方法的相關(guān)信息資訊供網(wǎng)民參考!
  • 推薦文章