最新国产好看的视频,伊人天堂AV在线,国产Aaaaaa视频,蜜臀视频在线观看一区,人妻av色图,密臀久久久精品影片,青青视频免费观看毛片,久草在线观看视,国产三级精品色情在线

python連接池實(shí)現(xiàn)示例程序

 更新時間:2013年11月26日 14:17:49   作者:  
這篇文章主要介紹了python連接池實(shí)現(xiàn),大家參考使用

復(fù)制代碼 代碼如下:

import socket
import Queue
import threading

def worker():
    while True:
        i = q.get()
        conn=i[0]
        addr=i[1]
        while 1:
            sms=conn.recv(1024)
            if sms!="":
                print "Message from ("+str(addr[0])+":"+str(addr[1])+"): "+sms
            else:
                print "Close the Connection from ("+str(addr[0])+":"+str(addr[1])+")"
                conn.close()
                break
        q.task_done()

if __name__=="__main__":
    q = Queue.Queue()
    thread_num=5000

    s=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
    s.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1)
    s.bind(("",4242))
    s.listen(50000)
    print "Server is listening at 4242"

    for _ in range(0,thread_num):
        t=threading.Thread(target=worker)
        t.setDaemon(1)
        t.start()

    while 1:
        conn,addr=s.accept()
        print "Connection come from ("+str(addr[0])+":"+str(addr[1])+")"
        q.put((conn,addr))

    q.join()

相關(guān)文章

最新評論

南溪县| 民乐县| 开封县| 调兵山市| 林口县| 加查县| 阿克陶县| 新野县| 宁海县| 靖州| 清涧县| 桐梓县| 梅州市| 沙河市| 新疆| 城固县| 瑞安市| 连州市| 神池县| 慈利县| 泽州县| 福州市| 祁阳县| 图们市| 南部县| 横山县| 鲁甸县| 广灵县| 富阳市| 兴安盟| 色达县| 敦化市| 维西| 乐东| 瑞金市| 凤阳县| 上杭县| 林西县| 阿克| 安徽省| 高雄县|