当前位置:首页 > 开发语言/框架 > perl/python

python_day9 历程池

优良自学吧提供python_day9 历程池,python_day9 进程池通过进程池 实现 socket   from multiprocessing import Process,Poolimport os,sysfrom socket import

python_day9 进程池

通过进程池 实现 socket

 

from multiprocessing import Process,Pool
import os,sys
from socket import *
import time
server=socket(AF_INET,SOCK_STREAM)
server.setsockopt(SOL_SOCKET,SO_REUSEADDR,1)
server.bind(('127.0.0.1',80))
server.listen(5)


def go(conn,addr):
while True:
try:
P=os.getpid()
data = conn.recv(1024)
print(P)
# conn.send(P)
except Exception as e:
print(e)
break


if __name__ == '__main__':
pool=Pool()
r_l=[]
while True:
conn,addr =server.accept()
res=pool.apply_async(go,args=(conn,addr))
r_l.append(res)

默认情况下 进程池中可以启动的进程数 是 CPU 的核数,我这里是4核
所以我用5个进程 测试, 当第5个客户端 试图 链接服务器的时候 现象是 等待服务器 返回;
实际上服务器是在处理前4个的请求, 当第一个的请求断掉了, 第5个连上了;
当这个时候, 第一个客户端 连上的 和 第5个客户端连上的 在服务器端 是同一个进程 处理的,也就是 同一个PID



 


(本文来自互联网,不代表搜站(http://www.ylzx8.cn/)的观点和立场)
本站所有内容来自互联网,若本站收录的信息无意侵犯了贵司版权,请给我们来信(ylzx8cn@163.com),我们会及时处理和回复,谢谢