进程池实现socket_server异步功能

# Time   : 2018/12/11 21:00

import socket
from multiprocessing import Pool


def (cn):
	# msg = input('>>>').encode('utf-8')
	cn.send(b'hello')
	ret = cn.recv(1024).decode('utf-8')
	print(ret)
	cn.close()


if __name__ == '__main__':
	p = Pool(5)
	sk = socket.socket()
	sk.bind(('127.0.0.1', 8080))
	sk.listen()
	while True:
		conn, addr = sk.accept()
		p.apply_async(func, args=(conn,))
	sk.close()

# Time   : 2018/12/11 21:00

import socket
sk = socket.socket()
sk.connect(('127.0.0.1', 8080))
ret = sk.recv(1024).decode('utf-8')
print(ret)
msg = input('>>>').encode('utf-8')
sk.send(msg)
sk.close()