码迷,mamicode.com
首页 > 其他好文 > 详细

使用池来实现并发服务器

时间:2018-01-23 20:31:26      阅读:150      评论:0      收藏:0      [点我收藏+]

标签:for   address   class   add   进程   count   线程池   post   sock   

#使用池来实现并发服务器
import socket
from multiprocessing import cpu_count,Pool
from multiprocessing.pool import ThreadPool

server=socket.socket()
server.bind((‘0.0.0.0‘,8080))
server.listen(1000)


def work_process(server):#处理server的进程
    thread_pool=ThreadPool(cpu_count())  #如果不想用线程池的话,可以直接用普通线程
    while True:
        connection,remote_address=server.accept()
        thread_pool.apply_async(worker_thread,args=(connection,))
def worker_thread(connection):
    while True:
        recv_data=connection.recv(1000)
        if recv_data:
            print(recv_data.decode(‘utf-8‘))
            connection.send(recv_data)
        else:
            connection.close()
            break
n=cpu_count() #获取cpu个数
pool=Pool(n)
for i in range(2):
    pool.apply_async(work_process,args=(server,))
pool.close()
pool.join()

使用池来实现并发服务器

标签:for   address   class   add   进程   count   线程池   post   sock   

原文地址:https://www.cnblogs.com/lajiao/p/8337096.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!