关于multiprocessing模块
当建立 可接受多个client连接的server的时后:#服务器端
from multiprocessing import Process
import socket
def talk(conn):# 定义功能
while True:
conn.send(b'hello')
msg = conn.recv(1024).decode('utf-8')
print(msg)
conn.close()
s = socket.socket()
s.bind(('127.0.0.1', 9001))
s.listen()
while True:# 每接受一个conn 就实例化一个Process
conn, addr = s.accept()
Process(target=talk, args=(conn,)).start()
#客户端1
import socket
c = socket.socket()
c.connect(('127.0.0.1', 9001))
while True:
c.send(b'im first')
msg = c.recv(1024).decode('utf-8')
print(msg)
#客户端2
import socket
c = socket.socket()
c.connect(('127.0.0.1', 9001))
while True:
c.send(b'im second')
msg = c.recv(1024).decode('utf-8')
print(msg)
执行结果为什么会出现 两个服务器的发送内容出现在同一行{:5_91:}
以下为执行结果
im first
im second
im first
im second
im first
im second
im firstim second
im first
im second
im first
im second
im first
im second
im first
im second
im firstim second
im firstim second
im first
im second
im first
im second
im first
im second
im first
im second
im firstim second
im second
im first
im second
im first
如果你进一步思考,会发现,出现 im firstim second 的下一行都是空字符串
这是因为 send, recv, print 三个函数,只在当前线程内保证顺序,在多线程之间,不保证顺序。
执行顺序可能出现
线程1: send// send(im first)
线程2: send// send(im second)
线程1: recv // recv(im first im second)
线程1: print// print(im first im second)
线程2: recv // recv('')
线程2: print // print('')
事实上,出现还有很多种情况,能得到你遇到的结果。 谢谢大佬{:5_95:}
页:
[1]